在Linux上Java的线程池使用

在Linux上，Java线程池的使用与在其他操作系统上并无太大差异

1. 导入必要的库：

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

2. 创建一个线程池：

int numberOfThreads = 10; // 设置线程池中的线程数量
ExecutorService executorService = Executors.newFixedThreadPool(numberOfThreads);

3. 提交任务到线程池：

for (int i = 0; i < 20; i++) {
    final int taskNumber = i;
    executorService.submit(() -> {
        System.out.println("Task " + taskNumber + " is running on thread " + Thread.currentThread().getName());
        try {
            TimeUnit.SECONDS.sleep(2); // 模拟任务执行时间
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    });
}

4. 关闭线程池：

在任务提交完成后，需要关闭线程池以释放资源。可以使用以下方法关闭线程池：

executorService.shutdown();

如果你希望在关闭线程池后等待所有任务完成，可以使用awaitTermination方法：

try {
    if (!executorService.awaitTermination(30, TimeUnit.SECONDS)) {
        executorService.shutdownNow();
    }
} catch (InterruptedException e) {
    executorService.shutdownNow();
}

5. 完整示例：

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

public class ThreadPoolExample {
    public static void main(String[] args) {
        int numberOfThreads = 10; // 设置线程池中的线程数量
        ExecutorService executorService = Executors.newFixedThreadPool(numberOfThreads);

        for (int i = 0; i < 20; i++) {
            final int taskNumber = i;
            executorService.submit(() -> {
                System.out.println("Task " + taskNumber + " is running on thread " + Thread.currentThread().getName());
                try {
                    TimeUnit.SECONDS.sleep(2); // 模拟任务执行时间
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            });
        }

        executorService.shutdown();
        try {
            if (!executorService.awaitTermination(30, TimeUnit.SECONDS)) {
                executorService.shutdownNow();
            }
        } catch (InterruptedException e) {
            executorService.shutdownNow();
        }
    }
}

这个示例创建了一个固定大小的线程池，并提交了20个任务。线程池在所有任务完成后关闭。