public LeaderFollowerWorkerThread(PoolTcpEndpoint endpoint) 
{
        this.endpoint = endpoint;
}

 public Object[] getInitData() 
{
        // no synchronization overhead, but 2 array access 
        Object obj[]=new Object[2];
        obj[1]= endpoint.getConnectionHandler().init();
        obj[0]=new TcpConnection();
        return obj;
}

 public  void runIt(Object[] perThrData) 
{
        // Create per-thread cache
        if (endpoint.isRunning()) {
            // Loop if endpoint is paused
            while (endpoint.isPaused()) {
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    // Ignore
                }
            }
            // Accept a new connection
            Socket s = null;
            try {
                s = endpoint.acceptSocket();
            } finally {
                // Continue accepting on another thread...
                if (endpoint.isRunning()) {
                    endpoint.tp.runIt(this);
                }
            }
            // Process the connection
            if (null != s) {
                endpoint.processSocket(s, (TcpConnection) perThrData[0], (Object[]) perThrData[1]);
            }
        }
}