java 线程池

 

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

public class FixThreadTest {

 public static void main(String[] args) {

  //创建一个最多同时运行3个任务的线程池
  ExecutorService service = Executors.newFixedThreadPool(5);
  
  service.execute(new MyThread("1"));
  service.execute(new MyThread("2"));
  service.execute(new MyThread("3"));
  service.execute(new MyThread("4"));
  service.execute(new MyThread("5"));
  service.execute(new MyThread("6"));
  service.execute(new MyThread("7"));
  service.execute(new MyThread("8"));
  service.execute(new MyThread("9"));
  service.execute(new MyThread("10"));
  
  for(int i=0;i<10000;i++){
   service.execute(new MyThread(String.valueOf(i+11)));
  }
  //结束线程池，不会马上结束，而是等所有安排的任务执行完才结束。
  //service.shutdown();
  
  try {
   System.out.println("***********");
   //如果不想马上结束，调用此方法等待一段时间
   service.awaitTermination(5, TimeUnit.SECONDS);
   System.out.println("---------------");
  } catch (InterruptedException e) {
   e.printStackTrace();
  }
  
  System.out.println("##########");
  service.shutdown();
 }

}

class MyThread implements Runnable{
 private String name;
 
 public MyThread(String name){
  this.name=name;
 }

 public void run() {
  try {
   Thread.sleep(20);
  } catch (InterruptedException e) {
   e.printStackTrace();
  }
  System.out.println("thread "+name);
 }
 
}