java线程池初探

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class TestThreadPool {

	private static int produceTaskSleepTime = 20;

	public static void main(String[] args) {
		
		int threadNum = 10;
		int taskNum = 100;
		
		ExecutorService threadPool = Executors.newFixedThreadPool(threadNum);

		for (int i = 0; i <= taskNum; i++) {

			try {
				threadPool.execute(new LoginTask(user));
				Thread.sleep(produceTaskSleepTime);
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}
}

 

public class LoginTask implements Runnable {

	public String user;
	

	public LoginTask(String user) {
		this.user = user;		
	}

	public void run() {
		
		//。。。。。
	}
}