百度建站国内搜索网站排名

百度建站,国内搜索网站排名,网站开发(源代码),网站建设开发ppt模板下载前面几篇我们把线程池的“池”讲透了#xff1a;ThreadPoolExecutor 的工作机制、拒绝策略、调优、定时任务#xff0c;以及生产级封装。 但在真实项目里#xff0c;最容易踩坑的并不是线程池参数#xff0c;而是——你到底是怎么把任务扔进去的#xff1a; execute() 和…前面几篇我们把线程池的“池”讲透了ThreadPoolExecutor 的工作机制、拒绝策略、调优、定时任务以及生产级封装。但在真实项目里最容易踩坑的并不是线程池参数而是——你到底是怎么把任务扔进去的execute()和submit()有什么区别为什么有人说 “submit 会吞异常”Runnable和Callable的本质差别是什么Future.get()为什么会把线程卡死超时、取消、中断到底怎么配合使用本篇把这条链路一次讲透。1. Runnable vs Callable差别就两点Runnable没返回值不能直接抛出受检异常只能内部 try/catchRunnable r () - System.out.println(run);CallableV有返回值V可以抛异常会体现在 Future 上CallableInteger c () - 1 1;句话记忆Runnable “干活不回话”Callable “干活还给结果或告诉你失败原因”2. execute vs submit这是面试必问点execute(Runnable)只接收 Runnable没有返回值如果任务抛异常异常会走线程的 uncaught 逻辑通常会打印栈但不回到调用方executor.execute(() - { throw new RuntimeException(boom); });submit(...)可以接收 Runnable / Callable返回 Future如果任务抛异常异常不会直接抛给调用方会被封装进 Future你不 get 就“像没发生过”Future? f executor.submit(() - { throw new RuntimeException(boom); });关键差异execute异常“向外冒”到线程层面submit异常“装进 Future”你不 get 就看不到3. submit 为啥“吞异常”——你不 get它就不报看这个最小复现ExecutorService pool Executors.newFixedThreadPool(1); pool.submit(() - { throw new RuntimeException(submit error); }); // 如果你不调用 get()很多情况下你不会在日志里看到异常栈正确姿势Future? f pool.submit(() - { throw new RuntimeException(submit error); }); try { f.get(); // 这里会抛 ExecutionException } catch (ExecutionException e) { System.out.println(真实异常 e.getCause()); } catch (Exception ignored) {}所以结论非常明确submit 不是真的吞异常它是把异常“延迟到 get() 时再抛”。你不 get就等于“你选择不看”。这也是为什么生产中你需要第五篇提到的SafeRunnable / 统一异常捕获。tipsJava 线程池第五篇生产级线程池封装方案统一命名、异常捕获、监控与超时控制4. Future 到底是什么它解决的是什么问题Future 的意义是你提交任务后立刻返回一个“凭证”你可以get()等结果阻塞get(timeout)限时等待避免卡死cancel(true)尝试取消 中断任务isDone()轮询是否完成核心接口V get() throws InterruptedException, ExecutionException; V get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException; boolean cancel(boolean mayInterruptIfRunning); boolean isDone(); boolean isCancelled();一句话理解Future 异步任务的“结果占位符” 控制手柄等待/超时/取消5. Future.get() 的最大坑会阻塞当前线程这是很多线上卡死的根源。FutureString f pool.submit(() - { Thread.sleep(5000); return OK; }); String r f.get(); // 这里会阻塞 5 秒什么时候 get 会出事你在Web 请求线程里 get请求线程被卡住 → 吞吐下降你在线程池内部的线程里 get 另一个同池任务可能造成线程饥饿甚至“伪死锁”经典坑同一个线程池互相等待ExecutorService pool Executors.newFixedThreadPool(1); FutureString f1 pool.submit(() - { FutureString f2 pool.submit(() - inner); // 没线程可跑 return f2.get(); // 永远等不到 }); System.out.println(f1.get());单线程池里提交嵌套任务 get 等待 直接卡死。6. 正确姿势get(timeout) cancel(true) 降级生产一定要习惯超时控制FutureString f pool.submit(() - { Thread.sleep(5000); return OK; }); try { String r f.get(2, TimeUnit.SECONDS); System.out.println(result r); } catch (TimeoutException e) { System.out.println(超时降级处理); f.cancel(true); // 尝试中断任务 } catch (ExecutionException e) { System.out.println(执行异常: e.getCause()); } catch (InterruptedException e) { Thread.currentThread().interrupt(); }注意cancel(true)只是请求中断任务是否能停取决于任务是否响应中断sleep/wait/阻塞 IO或主动检查Thread.currentThread().isInterrupted()7. submit(Runnable) 的返回值细节Future? / FutureT这也是容易误解的点submit(Runnable)返回Future?get()通常返回nullFuture? f pool.submit(() - System.out.println(hi)); System.out.println(f.get()); // nullsubmit(Runnable, T result)你可以指定一个固定结果少用但要知道FutureString f pool.submit(() - {}, OK); System.out.println(f.get()); // OKsubmit(CallableT)返回FutureTget()返回计算结果FutureInteger f pool.submit(() - 42); System.out.println(f.get()); // 428. execute 还是 submit怎么选直接给你决策表需求用哪个理由不关心返回值、只想丢给线程池跑execute简单直接需要拿结果submit(Callable)Future.get 拿返回值需要控制超时/取消submit get(timeout)Future 才能控制必须感知异常execute 或 submitgetexecute 异常更“显性”submit 需要 get大量 fire-and-forget 任务但又怕异常丢execute 统一异常捕获包装生产推荐第五篇方案一句工程建议业务里如果用 submit 但从不 get那你其实就是在“主动忽略异常”。要么 get要么统一包装捕获异常要么用 execute。9. 最佳实践把“任务提交”也工程化承接第五篇在第五篇已经有 ThreadPoolManager 了建议再加一个统一入口提交时强制包一层 SafeRunnable统一打点/日志统一命名 taskName示例public static Future? submitSafe(ExecutorService pool, Runnable r, String taskName) { return pool.submit(() - { try { r.run(); } catch (Throwable e) { System.err.println([TASK-EX] taskName thread Thread.currentThread().getName()); e.printStackTrace(); } }); }这样就算你不用 get也不会“无声失败”。10. 本篇总结背下来就够了Runnable无返回值Callable有返回值可抛异常execute无 Futuresubmit返回 Futuresubmit 的异常不会直接抛出必须 get 才看得到否则像“吞异常”Future.get 会阻塞生产必须 get(timeout) 并考虑 cancel(true) 与降级同池嵌套 submit get 可能卡死线程饥饿工程上要统一封装任务提交异常捕获、命名、监控