How does netty allocate worker thread to new request?

Question

In netty I create a channel factory as follows.

ChannelFactory factory = new NioServerSocketChannelFactory( Executors.newCachedThreadPool(threadFactory), Executors.newCachedThreadPool(threadFactory);

When a new request comes, how does the boss thread allocate a free worker thread to the new request from the workerthread pool? In which netty class can I find this logic?

score 1 · Answer 1 · edited Apr 27 '16 at 03:29

You can find the logic in NioServerBoss.class. Following is part of the netty source code.

   for (;;) {
      SocketChannel acceptedSocket = channel.socket.accept();
      if (acceptedSocket == null) {
          break;
      }
      registerAcceptedChannel(channel, acceptedSocket, thread);
   }

Part of registerAcceptedChannel:

NioWorker worker = parent.workerPool.nextWorker();
worker.register(new NioAcceptedSocketChannel(
        parent.getFactory(), pipeline, parent, sink
        , acceptedSocket,
        worker, currentThread), null);

The worker thread will check its taskQueue and run this new task.

score 0 · Answer 2 · edited May 23 '17 at 12:01

see here

Boss threads Each bound ServerSocketChannel has its own boss thread.

A boss thread accepts incoming connections until the port is unbound. Once a connection is accepted successfully, the boss thread passes the accepted Channel to one of the worker threads that the NioServerSocketChannelFactory manages.

from How Netty uses thread pools?

and now some thing will be improve

netty-issues-240

How does netty allocate worker thread to new request?

2 Answers2