Java并发工具类如ExecutorService的应用示例

原创 àì夳堔傛蜴生んèń 2024-09-16 15:06 91阅读 0赞

在Java中，`ExecutorService`是一个接口，它定义了如何管理和控制线程。以下是一个使用`ExecutorService`的简单示例：

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

public class ExecutorServiceExample {
    public static void main(String[] args) {
        // 创建一个固定大小的线程池
        ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 10, TimeUnit.SECONDS, new ArrayBlockingQueue<>(20)), // 线程池核心线程数，最大线程数，及阻塞队列容量 // Executors.newFixedThreadPool(5); // 创建线程

// 提交任务到线程池
        for (int i = 0; i < 10; i++) {
            Runnable task = () -> {
                System.out.println("Task " + i + " is running by thread: " + Thread.currentThread().getName());
                try {
                    Thread.sleep(500); // 模拟耗时操作
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println("Task " + i + " finished by thread: " + Thread.currentThread().getName());
            };

Future<?> future = executor.submit(task);
            try {
                future.get(); // 获取任务结果，可能会阻塞
            } catch (TimeoutException | InterruptedException e) {
                e.printStackTrace();
            }
        }

// 关闭线程池
        executor.shutdown();
    }
}
```

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