\n public   class  TestPool {\n     public   static   void  main(String[] args)  throws  InterruptedException {\n         new  PoolingServer().start();\n\n        Thread.sleep( 1000 );\n\n         int  count =  2 ;\n\n         for  ( int  i =  0 ; i < count; i++) {\n             new  PoolingClient().start();\n        }\n    }\n}\n

\n import  java.util.Random;\n import  java.net.Socket;\n import  java.io.IOException;\n import  java.io.OutputStream;\n import  java.io.InputStream;\n\n public   class  PoolingClient  extends  Thread {\n\n     private   int  id;\n\n     public   void  run() {\n         try  {\n             final  Socket s =  new  Socket("localhost",  12345 );\n            Random random =  new  Random();\n            id = random.nextInt();\n            OutputStream os = s.getOutputStream();\n             final  InputStream is = s.getInputStream();\n\n             new  Thread() {\n                 public   void  run() {\n                     while  (true) {\n                         try  {\n                             int  i = is.read();\n                            System.out.println("client #" + id + ", " + i);\n                        }  catch  (IOException e) {\n                            e.printStackTrace();\n                        }\n                    }\n                }\n            }.start();\n\n             while  (true) {\n                os.write(id);\n                os.flush();\n                Thread.sleep(random.nextInt( 1000 ));\n            }\n        }  catch  (IOException e) {\n            e.printStackTrace();\n        }  catch  (InterruptedException e) {\n            e.printStackTrace();\n        }\n    }\n}\n

\n import  java.net.ServerSocket;\n import  java.net.Socket;\n import  java.io.IOException;\n import  java.io.InputStream;\n import  java.io.OutputStream;\n import  java.util.*;\n\n public   class  PoolingServer  extends  Thread {\n\n    HashMap<Socket, PooledUser> users =  new  HashMap<Socket, PooledUser>();\n\n     public   void  run() {\n         try  {\n             new  ReadingThread().start();\n             new  SendingThread().start();\n\n            ServerSocket sock =  new  ServerSocket( 12345 );\n             while  (true) {\n                Socket s = sock.accept();\n                PooledUser user =  new  PooledUser();\n                user.socket = s;\n                user.input = s.getInputStream();\n                user.output = s.getOutputStream();\n                 synchronized (users) {\n                    users.put(s, user);\n                }\n            }\n        }  catch  (IOException e) {\n            e.printStackTrace();\n        }\n    }\n\n     private   static   class  PooledUser {\n        Socket socket;\n        InputStream input;\n        OutputStream output;\n        Vector<Integer> replies =  new  Vector<Integer>();\n    }\n\n     private   class  ReadingThread  extends  Thread {\n\n         public   void  run() {\n             while  (true) {\n                 synchronized  (users) {\n                     for  (Iterator<PooledUser> it = users.values().iterator(); it.hasNext(); ) {\n                        PooledUser user = it.next();\n                        InputStream is = user.input;\n                         try  {\n                             if  (is.available() >  0 ) {\n                                 int  x = is.read();\n                                x = -x;\n                                user.replies.add(x);\n                                yield();\n                            }\n                        }  catch  (IOException e) {\n                            e.printStackTrace();\n                        }\n                    }\n                }\n            }\n        }\n    }\n\n     private   class  SendingThread  extends  Thread {\n         public   void  run() {\n             while  (true) {\n                 synchronized  (users) {\n                     for  (Iterator<PooledUser> it = users.values().iterator(); it.hasNext(); ) {\n                        PooledUser user = it.next();\n                         if  (user.replies.size() >  0 ) {\n                             try  {\n                                user.output.write(user.replies.remove( 0 ));\n                                user.output.flush();\n                                yield();\n                            }  catch  (IOException e) {\n                                e.printStackTrace();\n                            }\n                        }\n                    }\n                }\n            }\n        }\n    }\n}\n

ServerSocket sock =  new  ServerSocket( 12345 ,  100 );