JAVA线程池专题（概念和作用）

线程池的作用

我们在用一个东西的时候，首先得搞明白一个问题。这玩意是干嘛的，为啥要用这个，用别的不行吗。那么一个一个解决这些问题

我们之前都用过数据库连接池，线程池的作用和连接池有点类似，频繁的创建，销毁线程会造成大量的不必要的性能开销，所以这个时候就出现了一个东西统一的管理线程，去负责线程啥时候销毁，啥时候创建，以及维持线程的状态，当程序需要使用线程的时候，直接从线程池拿，当程序用完了之后，直接把线程放回线程池，不需要去管线程的生命周期，专心的执行业务代码就行。

当然，如果非要是自己想手动new一个线程来执行，也不是不可以，只是像上面说的那样，第一麻烦，第二开销大，第三不好控制。

控制线程的方法

在说到线程池之前，首先要提到一个创建线程池的工具类，又或者说是工厂类 Executors 通过这个线程可以统一的创建线程，返回的是一个ExecutorService 类这个类中包含了一些对线程执行过程进行管理控制的方法；

void execute(Runnable command); 这个方法是将任务提交到线程池进行执行。这个方法没有返回值。

<T> Future<T> submit(Callable<T> task); 这个方法最特别的地方是线程执行完毕之后是有返回值的，另外方法的参数可以用Callable也可以为Runnable。可以适用于一些后续的代码，需要线程执行结果的程序。

下面的示例中，我们创建了一个 ExecutorService 的实例，提交了一个任务，然后使用返回的 Future 的 get() 方法等待提交的任务完成并返回值。

  ExecutorService executorService = Executors.newFixedThreadPool(10);
  Future<String> future = executorService.submit(() -> "Hello World");
  // 一些其它操作
  String result = future.get();

在实际使用时，我们并不会立即调用 future.get() 方法，可能会等待一些时间，推迟调用它直到我们需要它的值用于计算等目的。

ExecutorService 中的 submit() 方法被重载为支持 Runnable 或 Callable ，它们都是功能接口，可以接收一个 lambdas 作为参数（ 从 Jav

本文来源gao!%daima.com搞$代*!码$网3

a 8 开始 ）：

• 使用 Runnable 作为参数的方法不会抛出异常也不会返回任何值 ( 返回 void )
• 使用 Callable 作为参数的方法则可以抛出异常也可以返回值。

如果想让编译器将参数推断为 Callable 类型，只需要 lambda 返回一个值即可。

• void shutdown(); 在调用了shutdown方法之后，线程池就不会再接收新的任务，此时线程池还没有停止，仍然会把线程池中国正在执行但是还没有执行完的任务继续执行完毕，那些没有开始执行的任务则被中断
• List<Runnable> shutdownNow(); 在调用了shutdownNow方法之后，会将线程池的状态设置为stop，正在执行的任务则被停止，没被执行任务的则返回。

这两种方法的使用场景：如果线程中的任务相互之间没有什么关联某个线程的异常对结果影响不大。那么所有线程都能在执行任务结束之后可以正常结束，程序能在所有task都做完之后正常退出，适合用ShutDown。但是，如果一个线程在做某个任务的时候失败，则整个结果就是失败的，其他worker再继续做剩下的任务也是徒劳，这就需要让他们全部停止当前的工作。这里使用ShutDownNow就可以让该pool中的所有线程都停止当前的工作，从而迫使所有线程执行退出。从而让主程序正常退出。

喜欢 (0)赏

[搞代码]

分享 (0)