代码如下:
主方法:
package com.java.day21ThreadPool; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; /*线程池创建步骤 * 1.使用线程池的工厂类,Executors里面提供的静态方法newFixedThreadPool,创建一个线程池 * 2.创建一个类,实现Runnable接口,重写run方法,设置线程任务 * 3.传递线程任务,开启线程,执行任务 * */ public class ThreadPool { public static void main(String[] args) { ExecutorService es = Executors.newFixedThreadPool(3); RunnableApi ra = new RunnableApi(); // 传递线程任务 es.submit(ra); es.submit(new RunnableApi()); es.submit(new RunnableApi()); } }
任务类:
package com.java.day21ThreadPool; public class RunnableApi implements Runnable{ @Override public void run() { System.out.println(Thread.currentThread().getName()+"创建了一个新的线程"); } }