import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors;java
/** *ide
*/ public class TestThread { public static void main(String args[]){ //建立一个可重用固定线程数的线程池 ExecutorService pool = Executors.newFixedThreadPool(4);线程
//建立一个使用单个 worker 线程的 Executor,以无界队列方式来运行该线程。
// ExecutorService pool = Executors.newSingleThreadExecutor(); //建立实现了runnable接口的对象 Thread t1 = new MyThread(); Thread t2 = new MyThread(); Thread t3 = new MyThread(); Thread t4 = new MyThread(); Thread t5 = new MyThread(); //将线程放入池中进行执行 pool.execute(t1); pool.execute(t2); pool.execute(t3); pool.execute(t4); pool.execute(t5); //关闭线程池 pool.shutdown(); } } class MyThread extends Thread{code
@Override public void run(){ System.out.println(Thread.currentThread().getName()+" is running..."); }
}对象
输出结果: pool-1-thread-1 is running... pool-1-thread-1 is running... pool-1-thread-3 is running... pool-1-thread-2 is running... pool-1-thread-4 is running...接口