启动新线程,需要和操作系统进行交互,成本比较高。 使用线程池可以提高性能——
线程池会提前创建大量的空闲线程,随时待命执行线程任务。在执行完了一个任务之后,线程会回到空闲状态,等待执行下一个任务。(这个任务,就是Runnable的run()方法,或Callable的call()方法)。
Java 5之前需要手动实现线程池,Java 5之后直接支持线程池。
Java.util.concurrent. Executors:用于创建线程池 |--|--Executors.newFixedThreadPool():创建有固定线程数量的线程池
Java.util.concurrent.ExecutorService:尽快执行线程的线程池(有空闲线程就即刻执行)
ExecutorService对象的submit()方法用于提交Runnable或Callable对象
不再提交任务是,调用ExecutorService对象的shutdown()方法关闭线程池,线程池不再接受新的任务,但会把之前的任务执行完毕。
package ahjava.p06thread; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; // Executors:用于创建线程池 // .newFixedThreadPool():创建有固定线程数量的线程池 // ExecutorService:尽快执行线程的线程池(有空闲线程就即刻执行) public class _51ThreadPoolTest { public static void main(String[] args) throws Exception { // 创建一个具有固定线程数(6)的线程池 ExecutorService pool = Executors.newFixedThreadPool(6); Runnable target = new Runnable() { @Override public void run() { for (int i = 0; i < 100; i++) { String name = Thread.currentThread().getName(); System.out.println(name + ":" + i); } } }; // 向线程池中提交两个线程 pool.submit(target); pool.submit(target); // 关闭线程池 pool.shutdown(); } }