new ThreadPoolExecutor(corePoolSize,maximumPoolSize,keepAliveTime,timeunit,runnableTaskQueue,handler)
通常使用工厂类Executors创建:
1.FixedThreadPool:满足资源管理的需求,适合负载比较重的服务器
public static ExecutorService newFixedThreadPool(int nThreads)
public static ExecutorService newFixedThreadPool(int nThreads,ThreadFactory threadFactory)
源代码:
public static
2.SingleThreadPool: 满足保证顺序的执行每个任务,并且在任意时间点,不会有多个线程是活动的场景
public static ExecutorService newSingleThreadPool()
public static ExecutorService newSingleThreadPool(ThreadFactory threadFactory)
3.CachedThreadPool:大小无界,适用于很多短期异步的小程序,或者是负载较轻的服务器
public static ExecutorService newCachedThreadPool()
public static ExecutorService newCachedThreadPool(ThreadFactory threadFactory)
使用工厂类Executors创建 1.ScheduledThreadPoolExecutor:
public static ExecutorService newScheduledThreadPool(int nThreads)
public static ExecutorService newScheduledThreadPool(int nThreads,ThreadFactory threadFactory)
2.SingleThreadScheduledExecutor:
public static ExecutorService newSingleThreadScheduledExecutor()
public static ExecutorService newSingleThreadScheduledExecutor(ThreadFactory threadFactory)
当我们把Runnable接口或者Callable接口submit给ThreadPoolExecutor时,会返回一个FutureTask对象,API:
<T> Future<T> submit(Callable<T> Task)
<T> Future<T> submit(Runnable Task,T result)
Future> submit(Runnable Task)
Executors提供的:
public static Callable callable(Runnable task)
public static Callable callable(Runnable task,T Result)