Java并发工具线程池使用不当问题案例-蒲公英云

Java并发工具线程池使用不当问题案例

原创野性酷女 2024-12-12 04:21 87阅读 0赞

在Java编程中，线程池是一种常用的并发资源管理工具。如果使用不当，可能会引发一些问题。下面提供一个典型的案例：

案例：多线程任务的超时问题

假设我们有一个任务类Task，它需要执行一些耗时的操作。我们希望通过一个线程池来批量处理这些任务。

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ThreadPoolExample {
    private ExecutorService executorService;
    public ThreadPoolExample(int threadCount) {
        this.executorService = Executors.newFixedThreadPool(threadCount);
    }
    // 任务类
    public static class Task implements Runnable {
        private final String taskName;
        public Task(String taskName) {
            this.taskName = taskName;
        }
        @Override
        public void run() {
            System.out.println("Task " + taskName + " started...");
            try {
                // 耗时操作
                Thread.sleep(5000); // 5秒
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("Task " + taskName + " finished...");
        }
    }
    public void submitTasks() {
        for (int i = 1; i <= 10; i++) { // 任务数量
            String taskName = "Task " + i;
            executorService.submit(new Task(taskName)));
        }
    }
    public static void main(String[] args) {
        ThreadPoolExample example = new ThreadPoolExample(5); // 创建线程池，大小为5
        example.submitTasks(); // 提交任务
        executorService.shutdown(); // 关闭线程池
    }
}