阅读量:1
在Java中,可以通过配置ThreadPoolExecutor的构造器来创建一个线程池,并设置一些参数来控制线程池的行为。下面是一个示例代码,演示了如何配置ThreadPoolExecutor:
import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; public class Main { public static void main(String[] args) { // 创建一个线程池,其中包含5个线程 ThreadPoolExecutor executor = new ThreadPoolExecutor( 5, // 核心线程数 10, // 最大线程数 60, // 空闲线程存活时间 TimeUnit.SECONDS, // 时间单位 new LinkedBlockingQueue<Runnable>() // 阻塞队列 ); // 设置拒绝策略为直接抛出异常 executor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy()); // 执行任务 executor.execute(new MyTask()); // 关闭线程池 executor.shutdown(); } } class MyTask implements Runnable { @Override public void run() { System.out.println("Hello from MyTask!"); } }
在上面的示例代码中,我们创建了一个ThreadPoolExecutor对象,并设置了核心线程数为5,最大线程数为10,空闲线程存活时间为60秒,阻塞队列为LinkedBlockingQueue。然后我们设置了拒绝策略为直接抛出异常,最后执行了一个任务并关闭了线程池。你可以根据自己的需求来配置ThreadPoolExecutor的参数,以满足不同的场景需求。