并发编程：Java中的线程池使用示例

原创﹏ヽ暗。殇╰゛Y 2024-09-12 10:27 104阅读 0赞

在Java中，线程池是一种常用的管理线程的方式。它能够重复利用已创建的线程，避免频繁地创建和销毁线程，从而提高了系统的效率。

以下是一个简单的Java线程池使用示例：

```java
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ThreadPoolExample {

public static void main(String[] args) {
        // 创建一个固定大小的线程池
        ExecutorService executor = Executors.newFixedThreadPool(5); // 设置线程池大小

// 提交任务到线程池
        for (int i = 0; i < 10; i++) { // 每个任务执行1秒
            executor.submit(new Task(i)); // 提交任务到线程池
        }

// 关闭线程池，不再接受新的任务
        executor.shutdown();

// 等待所有任务完成或者线程池关闭后才退出程序
        while (!executor.isTerminated()) {
            try {
                Thread.sleep(100); // 每秒检查一次
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

executor.shutdownNow(); // 移除已经提交但还未完成的任务
    }

static class Task implements Runnable {

private int index;

public Task(int index) {
            this.index = index;
        }

@Override
        public void run() {
            try {
                System.out.println("Task " + index + " is running..."); // 输出任务运行状态

Thread.sleep(1000); // 模拟任务执行时间，这里设置为1秒

System.out.println("Task " + index + " has finished."); // 任务执行完成后的输出

} catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}
```

这个示例中创建了一个固定大小的线程池，然后提交了10个任务到线程池。每个任务模拟执行时间，并在完成后打印一条消息。最后，关闭线程池以释放资源。