concurrencyexample.java

一步 教你学会java 完成一个完整的SWT系统 是本人学习java时按教程一步一步写下来的咯

/**
 *  
 *  Concurrency utilities (JSR-166) example
 **/
package threadpool;

import java.net.*;
import java.io.*;
import java.util.concurrent.*;

public class ConcurrencyExample {
  private final static int MAX_THREADS = 2;

  private final ServerSocket serverSocket;
  private final ExecutorService executor;
  

  /**
   *  Constructor
   **/
  public ConcurrencyExample(int port, int poolSize) throws IOException {
    /*  Create a new ServerSocket to listen for incoming connections  */
    serverSocket = new ServerSocket(port);

    /*  Use the Exectors factory method to get a ThreadPool  */
    executor = Executors.newFixedThreadPool(MAX_THREADS);
  }

  /**
   *  Service requests
   **/
  public void serviceRequests() {
    int count = 1;
    int qLength = 0;

    try {
      for (;;) {
        executor.execute(new ConnectionHandler(serverSocket.accept(), count++));
      }
    } catch (IOException ioe) {
      System.out.println("IO Error in ConnectionHandler: " + ioe.getMessage());
      executor.shutdown();
    }
  }

  /**
   *  Main entry point
   *
   * @param args Command line arguments
   **/
  public static void main(String[] args) {
    System.out.println("Listening for connections...");
    ConcurrencyExample ce = null;

    try {
      ce = new ConcurrencyExample(8100, 4);
      ce.serviceRequests();
    } catch (IOException ioe) {
      System.out.println("IO Error creating listener: " + ioe.getMessage());
    }
  }
}