Examples of java.nio.channels.Selector.select()

java.nio.channels.Selector.select()
Selects a set of keys whose corresponding channels are ready for I/O operations.
This method performs a blocking selection operation. It returns only after at least one channel is selected, this selector's {@link #wakeup wakeup} method is invoked, the currentthread is interrupted, or the given timeout period expires, whichever comes first.
This method does not offer real-time guarantees: It schedules the timeout as if by invoking the {@link Object#wait(long)} method.
@param timeout If positive, block for up to timeoutmilliseconds, more or less, while waiting for a channel to become ready; if zero, block indefinitely; must not be negative @return The number of keys, possibly zero,whose ready-operation sets were updated @throws IOException If an I/O error occurs @throws ClosedSelectorException If this selector is closed @throws IllegalArgumentException If the value of the timeout argument is negative

    private class Worker implements Runnable {
        public void run() {
            Selector selector = getSelector();
            for (;;) {
                try {
                    int nKeys = selector.select();


                    registerNew();


                    if (nKeys > 0) {
                        processSessions(selector.selectedKeys());

View Full Code Here


        public void run() {
            Selector selector = getSelector();
            for (;;) {
                try {
                    int nKeys = selector.select(1000);


                    registerNew();


                    if (nKeys > 0) {
                        processSessions(selector.selectedKeys());

View Full Code Here

                start = System.currentTimeMillis();
            }
            sender.setMessage(buf);
            int selectedKeys = 0;
            try {
                selectedKeys = selector.select(0);
            } catch (Exception e) {
                e.printStackTrace();
                continue;
            }

View Full Code Here

                start = System.currentTimeMillis();
            }
            sender.setMessage(buf);
            int selectedKeys = 0;
            try {
                selectedKeys = selector.select(0);
            } catch (Exception e) {
                e.printStackTrace();
                continue;
            }

View Full Code Here

                start = System.currentTimeMillis();
            }
            sender.setMessage(buf);
            int selectedKeys = 0;
            try {
                selectedKeys = selector.select(0);
            } catch (Exception e) {
                e.printStackTrace();
                continue;
            }

View Full Code Here

                }
                count = 1;
                tmpKey = socketChannel
                        .register(readSelector,SelectionKey.OP_READ);
                tmpKey.interestOps(tmpKey.interestOps() | SelectionKey.OP_READ);
                int code = readSelector.select(readTimeout);
                tmpKey.interestOps(
                        tmpKey.interestOps() & (~SelectionKey.OP_READ));


                if ( code == 0 ){
                    return 0; // Return on the main Selector and try again.

View Full Code Here

    private class Worker implements Runnable {
        public void run() {
            Selector selector = SocketIoProcessor.this.selector;
            for (;;) {
                try {
                    int nKeys = selector.select(1000);
                    doAddNew();
                    doUpdateTrafficMask();


                    if (nKeys > 0) {
                        process(selector.selectedKeys());

View Full Code Here

            // this may block for a long time, upon return the
            // selected set contains keys of the ready channels
            try {


                //System.out.println("Selecting with timeout="+timeout);
                int n = selector.select(timeout);
                //System.out.println("select returned="+n);
                if (n == 0) {
                    continue; // nothing to do
                }
                // get an iterator over the set of selected keys

View Full Code Here

                    // from acquiring its lock.
                selectorGuard.writeLock().unlock();
            }


            try {
                int selectedKeyCount = selector.select(500);


                // Wake up immediately in the next turn if someone might
                // have waken up the selector between 'wakenUp.set(false)'
                // and 'selector.select(...)'.
                if (wakenUp.get()) {

View Full Code Here

                NativeServerSocketChannel ch = serverSocket(baseport + i);
                ch.configureBlocking(false);
                ch.register(selector, SelectionKey.OP_ACCEPT, new Accepter(selector, ch));
            }
            while (true) {
                selector.select();
                for (SelectionKey k : selector.selectedKeys()) {
                    if ((k.readyOps() & (SelectionKey.OP_READ | SelectionKey.OP_ACCEPT)) != 0) {
                        ((IO) k.attachment()).read();
                    }
                    if ((k.readyOps() & (SelectionKey.OP_WRITE | SelectionKey.OP_CONNECT)) != 0) {

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.