共计 803 个字符,预计需要花费 3 分钟才能阅读完成。
Java 中创建线程池的代码可以按照以下步骤进行:
- 导入相关的类和包:
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
- 创建一个线程池对象:
ExecutorService executor = Executors.newFixedThreadPool(5);
这里使用 Executors.newFixedThreadPool()
方法创建一个固定大小的线程池,参数 5 表示线程池中的线程数量为 5。
- 定义一个实现 Runnable 接口的任务类:
class MyTask implements Runnable {public void run() {// 执行任务逻辑
}
}
- 提交任务给线程池:
executor.submit(new MyTask());
这里使用 submit()
方法将任务提交给线程池进行执行。
- 关闭线程池:
executor.shutdown();
在任务执行完毕后,需要调用 shutdown()
方法关闭线程池。
完整的示例代码如下所示:
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
class MyTask implements Runnable {public void run() {// 执行任务逻辑
}
}
public class ThreadPoolExample {public static void main(String[] args) {ExecutorService executor = Executors.newFixedThreadPool(5);
for (int i = 0; i < 10; i++) {executor.submit(new MyTask());
}
executor.shutdown();}
}
丸趣 TV 网 – 提供最优质的资源集合!
正文完