public MasterSlaveWorkerThread(PoolTcpEndpoint endpoint,
    String threadName) 
{
    
        this.endpoint = endpoint;
        this.threadName = threadName;
}

 synchronized  void assign(Socket socket) 
{
        // Wait for the Processor to get the previous Socket
        while (available) {
            try {
                wait();
            } catch (InterruptedException e) {
            }
        }
        // Store the newly available Socket and notify our thread
        this.socket = socket;
        available = true;
        notifyAll();
}

Process an incoming TCP/IP connection on the specified socket. Any exception that occurs during processing must be logged and swallowed. NOTE: This method is called from our Connector's thread. We must assign it to our own thread so that multiple simultaneous requests can be handled.

 public  void run() 
{
        // Process requests until we receive a shutdown signal
        while (!stopped) {
            // Wait for the next socket to be assigned
            Socket socket = await();
            if (socket == null)
                continue;
            // Process the request from this socket
            endpoint.processSocket(socket, con, threadData);
            // Finish up this request
            endpoint.recycleWorkerThread(this);
        }
        // Tell threadStop() we have shut ourselves down successfully
        synchronized (threadSync) {
            threadSync.notifyAll();
        }
}

The background thread that listens for incoming TCP/IP connections and hands them off to an appropriate processor.

 public  void start() 
{
        threadData = endpoint.getConnectionHandler().init();
        thread = new ThreadWithAttributes(null, this);
        thread.setName(threadName);
        thread.setDaemon(true);
        thread.start();
}

Start the background processing thread.

 public  void stop() 
{
        stopped = true;
        assign(null);
        thread = null;
        threadData = null;
}

Stop the background processing thread.