【零基础到精通Java合集】第十八集:多线程与并发编程-线程池与Callable/Future应用
课程标题:线程池与Callable/Future应用(15分钟)
目标:掌握线程池的创建与管理,理解Callable任务与Future异步结果处理机制
0-1分钟:课程引入与线程池意义
以“银行窗口服务”类比线程池:复用固定资源(柜员)处理多任务(客户)。说明线程池的核心价值——避免频繁创建/销毁线程的开销,控制并发规模。
1-2分钟:线程池的创建方式
演示通过Executors
工具类快速创建线程池:
ExecutorService fixedPool = Executors.newFixedThreadPool(4); // 固定线程数
ExecutorService cachedPool = Executors.newCachedThreadPool(); // 弹性扩容
ScheduledExecutorService scheduledPool = Executors.newScheduledThreadPool(2); // 定时任务
2-4分钟:ThreadPoolExecutor核心参数
手动配置线程池(更灵活):
ThreadPoolExecutor customPool = new ThreadPoolExecutor(
2, // 核心线程数
10, // 最大线程数
60, TimeUnit.SECONDS, // 空闲线程存活时间
new LinkedBlockingQueue<>(100) // 任务队列
);
拒绝策略:当队列满且线程数达上限时,可定义AbortPolicy
(抛异常)或CallerRunsPolicy
(调用方线程执行任务)。
4-5分钟:Callable与Runnable的对比
- Runnable:无返回值,不抛异常
Runnable task = () -> System.out.println("执行任务");
- Callable:有返回值,支持异常
Callable<Integer> task