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 = DatagramAcceptorDelegate.this.getSelector();
            for (;;) {
                try {
                    int nKeys = selector.select();


                    registerNew();


                    if (nKeys > 0) {
                        processReadySessions(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

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


                    registerNew();
                    doUpdateTrafficMask();


                    if (nKeys > 0) {

View Full Code Here

    private class Worker implements Runnable {
        public void run() {
            Selector selector = getSelector();
            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 {
                events();
                socketTimeouts();
                int n = selector.select(getSelectorTimeout());
                if (n == 0) {
                    //there is a good chance that we got here
                    //because the TcpReplicationThread called
                    //selector wakeup().
                    //if that happens, we must ensure that that

View Full Code Here

            Thread.currentThread().setName("DatagramAcceptor-" + id);


            Selector selector = DatagramAcceptorDelegate.this.getSelector();
            for (;;) {
                try {
                    int nKeys = selector.select();


                    registerNew();


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

View Full Code Here

            Thread.currentThread().setName("DatagramConnector-" + id);


            Selector selector = getSelector();
            for (;;) {
                try {
                    int nKeys = selector.select();


                    registerNew();
                    doUpdateTrafficMask();


                    if (nKeys > 0) {

View Full Code Here

            Thread.currentThread().setName(SocketIoProcessor.this.threadName);


            Selector selector = getSelector();
            for (;;) {
                try {
                    int nKeys = selector.select(1000);
                    doAddNew();
                    doUpdateTrafficMask();


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

View Full Code Here

            Thread.currentThread().setName(SocketAcceptor.this.threadName);


            Selector selector = getSelector();
            for (;;) {
                try {
                    int nKeys = selector.select();


                    registerNew();


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

View Full Code Here

            Thread.currentThread().setName(SocketConnector.this.threadName);


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


                    registerNew();


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

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.