并发编程挑战：Java线程池管理示例

原创水深无声 2024-11-15 15:00 2阅读 0赞

在Java中，线程池是一个重要的并发工具，它能够重复使用已经创建的线程，从而有效管理系统的并发程度。

以下是一个简单的Java线程池管理示例：

```java
import java.util.concurrent.*;

public class ThreadPoolExample {
    // 创建一个固定大小的线程池
    public static ExecutorService fixedThreadPool = Executors.newFixedThreadPool(5);  // 运行任务

public static void main(String[] args) {
        // 提交任务到线程池
        for (int i = 0; i < 10; i++) {
            fixedThreadPool.execute(new Task(i, "Task " + i))));
        }

// 关闭线程池，防止资源泄露
        fixedThreadPool.shutdown();
    }
}

class Task implements Runnable {
    private int id;
    private String taskName;

public Task(int id, String taskName) {
        this.id = id;
        this.taskName = taskName;
    }

@Override
    public void run() {
        System.out.println("Task " + id + " started by " + Thread.currentThread().getName());
        try {
            Thread.sleep(2000);  // 模拟耗时任务
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("Task " + id + " finished by " + Thread.currentThread().getName());
    }
}
```

这个示例中，我们创建了一个固定大小的线程池（5个线程），然后提交了10个任务到线程池。每个任务都是一个实现了Runnable接口的类实例。

当所有任务完成时，我们关闭线程池以释放资源。