Java 线程池示例代码:创建固定线程池执行任务
下面是一个简单的线程池Java代码示例:
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ThreadPoolExample {
public static void main(String[] args) {
// 创建一个线程池,最多同时执行5个线程
ExecutorService executor = Executors.newFixedThreadPool(5);
// 提交10个任务给线程池执行
for (int i = 1; i <= 10; i++) {
executor.execute(new Task(i));
}
// 关闭线程池
executor.shutdown();
}
private static class Task implements Runnable {
private int id;
public Task(int id) {
this.id = id;
}
@Override
public void run() {
System.out.println('Task ' + id + ' is running on thread ' + Thread.currentThread().getName());
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println('Task ' + id + ' is complete');
}
}
}
以上代码使用了Java的线程池框架,通过创建一个固定数量的线程池来执行一系列任务。每个任务都是一个实现了Runnable接口的类,可以在run()方法中定义具体的任务逻辑。在这个例子中,每个任务都会休眠1秒钟,模拟一个耗时的操作。最后,当所有任务都执行完毕后,线程池会被关闭。
原文地址: https://www.cveoy.top/t/topic/oZIy 著作权归作者所有。请勿转载和采集!