JDK1.5 引入了 Executor框架 ,对任务提交和执行进行解耦 , 定义任务后交由线程池执行。
线程池是由java.util.concurrent 包中Executors类的工厂方法创建线程池。
--------------------------------------------------------------------------------
创建一个可重用固定线程数的线程池,以共享的*队列方式来运行这些线程。
public static ExecutorService newFixedThreadPool(int nThreads) nThreads
- 池中的线程数
ExecutorService pool = Executors.newFixedThreadPool(6);
创建一个使用单个 worker 线程的 Executor,以*队列方式来运行该线程。
public static ExecutorService newSingleThreadExecutor()
ExecutorService threadPool = Executors.newSingleThreadExecutor();
创建一个安排在给定延迟后运行命令或者定期地执行的拥有3个线程的线程池。
初始延迟为6秒 , 间隔定时为2秒 的定时任务。
Executors.newScheduledThreadPool(3).scheduleAtFixedRate( ()-> { System.out.println("bombing!"); }, 6, 2, TimeUnit.SECONDS); }
创建一个使用单个 worker 线程的 Executor,以*队列方式来运行该线程。
public static ExecutorService newSingleThreadExecutor()
--------------------------------------------------------------------------------
线程池框架提供了两种方式提交任务,根据不同的业务需求选择不同的方式。
① Executor.execute()
void execute(Runnable command)
在未来某个时间执行给定的命令。该命令可能在新的线程、已入池的线程或者正调用的线程中执行,这由 Executor 实现决定。
② ExecutorService.submit()
|
submit(Callable<T> task) 提交一个返回值的任务用于执行,返回一个表示任务的未决结Future。 |
|
Future <?>
|
submit(Runnable task) 提交一个 Runnable 任务用于执行,并返回一个表示该任务的 Future。 |
|
|
submit(Runnable task, T result) 提交一个 Runnable 任务用于执行,并返回一个表示该任务的 Future。 |
两个方法都可以向线程池提交任务,execute()方法的返回类型是void,它定义在Executor接口中,
而submit()方法可以返回持有计算结果的Future对象,它定义在ExecutorService接口中
https://www.jianshu.com/p/87bff5cc8d8c
深度剖析Executor框架 ↓↓↓
https://blog.csdn.net/javazejian/article/details/50890554