JAVA封装多线程实现的方式及原理

import java.util.concurrent.*;
// 实现 Runnable 接口的任务类
class MyRunnableTask implements Runnable {
    @Override
    public void run() {
        System.out.println("Runnable 任务正在执行，线程名: " + Thread.currentThread().getName());
    }
}
// 实现 Callable 接口的任务类
class MyCallableTask implements Callable<String> {
    @Override
    public String call() throws Exception {
        return "Callable 任务执行结果，线程名: " + Thread.currentThread().getName();
    }
}
public class ThreadTaskWrapper {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        // 使用 Runnable 任务
        Thread runnableThread = new Thread(new MyRunnableTask());
        runnableThread.start();
        // 使用 Callable 任务
        ExecutorService executor = Executors.newSingleThreadExecutor();
        Future<String> future = executor.submit(new MyCallableTask());
        String result = future.get();
        System.out.println(result);
        executor.shutdown();
    }
}

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
// 封装线程池的类
class ThreadPoolWrapper {
    private final ExecutorService executor;
    public ThreadPoolWrapper(int poolSize) {
        this.executor = Executors.newFixedThreadPool(poolSize);
    }
    public void submitTask(Runnable task) {
        executor.submit(task);
    }
    public void shutdown() {
        executor.shutdown();
    }
}
// 使用封装的线程池
public class Main {
    public static void main(String[] args) {
        ThreadPoolWrapper threadPool = new ThreadPoolWrapper(3);
        for (int i = 0; i < 5; i++) {
            final int taskId = i;
            threadPool.submitTask(() -> {
                System.out.println("任务 " + taskId + " 正在执行，线程名: " + Thread.currentThread().getName());
            });
        }
        threadPool.shutdown();
    }
}