mina使用スレッドプール例およびsocket同時テスト

ExecutorService executor = Executors.newFixedThreadPool(1000);
        
        IoAcceptor acceptor = new NioSocketAcceptor();
        

        acceptor.setHandler(  new TimeServerHandler() );

        acceptor.getSessionConfig().setReadBufferSize( 2048 );
        acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE, 10 );
        
        acceptor.getFilterChain().addLast("executor",
                new ExecutorFilter(executor));
        acceptor.getFilterChain().addLast( "logger", new LoggingFilter() );
        acceptor.getFilterChain().addLast(
                "codec",
                new ProtocolCodecFilter( new ObjectSerializationCodecFactory() ) ); 
        acceptor.bind( new InetSocketAddress(PORT) );

 public static void main( String[] args ) throws Throwable   
	     {   
	    	 for(int i=0;i<1000;i++){
	 			log.info("Enter run l..."+i);
	 			new Thread(new ClientThread(i)).start();
	 		}
	   
	     }    

public void run() {
		// TODO Auto-generated method stub
		log.info("#### thread :"+this.num+" Running...");
		NioSocketConnector connector = new NioSocketConnector();
        // Configure the service.
        
        connector.setConnectTimeoutMillis(CONNECT_TIMEOUT);
        
       
        connector.getFilterChain().addLast(
                    "codec",
                    new ProtocolCodecFilter( new ObjectSerializationCodecFactory() ) );

        connector.getFilterChain().addLast( "logger", new LoggingFilter() );
        connector.setHandler(new ClientSessionHandler(" hihi new!"));
        
       
        IoSession session;
        for (;;) {
            try {
                ConnectFuture future = connector.connect(new InetSocketAddress(
                        HOSTNAME, PORT));

                future.awaitUninterruptibly();
                session = future.getSession();
                break;
            } catch (Exception e) {
                System.err.println("Failed to connect.");
                e.printStackTrace();
               
            }
        }

        // wait until the summation is done
        session.getCloseFuture().awaitUninterruptibly();
        
        connector.dispose();
        log.info("#### thread :"+this.num+" over ...");
		
	}

2008-12-28 02:18:06,968 ERROR (LoggingFilter.java:127) - EXCEPTION :
java.io.IOException:   。
	at sun.nio.ch.SocketDispatcher.read0(Native Method)
	at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:25)
	at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:233)
	at sun.nio.ch.IOUtil.read(IOUtil.java:206)
	at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:207)
	at org.apache.mina.transport.socket.nio.NioProcessor.read(NioProcessor.java:180)
	at org.apache.mina.transport.socket.nio.NioProcessor.read(NioProcessor.java:42)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor.read(AbstractPollingIoProcessor.java:568)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor.process(AbstractPollingIoProcessor.java:547)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor.process(AbstractPollingIoProcessor.java:539)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor.access$400(AbstractPollingIoProcessor.java:57)
	at org.apache.mina.core.polling.AbstractPollingIoProcessor$Processor.run(AbstractPollingIoProcessor.java:867)
	at org.apache.mina.util.NamePreservingRunnable.run(NamePreservingRunnable.java:65)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675)
	at java.lang.Thread.run(Thread.java:595)