併發-執行緒池-Executor框架

Executor框架：

為了更好的控制多執行緒，JDk提供了一套執行緒框架Executor,位於java.util.concurrent包下，是JDK併發包的核心。其中重要的一個角色：Executors,扮演執行緒工廠的角色，用於建立執行緒

主要方法包含：

1、該方法返回一個固定數量的執行緒池，方法的執行緒數量不變，有一個任務提交時，若執行緒池中有空閒，則立即執行，若沒有，則會被快取在一個任務佇列中等待有空閒的執行緒去執行。

newFixedThreadPool() 

2、 建立一個執行緒的執行緒池，若空閒則執行，若沒有空閒的執行緒，則暫緩於任務佇列中

newSingleThreadExecutor()

3、方法返回一個可根據實際情況調整執行緒個數的執行緒池，預設初始化時是不建立執行緒的，不限制最大執行緒數量。若有空閒的執行緒則去執行任務，若無任務則不建立執行緒，並且每個空閒的執行緒會在60秒後自動回收。

newCachedThreadPool()

4、該方法返回一個ScheduledExecutorService物件，定時器機制的job去執行，但是執行緒池可以指定執行緒的數量

newScheduledThreadPool()

均是由ThreadPoolExecutor建立而來。

public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
             BlockingQueue<Runnable> workQueue,
             ThreadFactory threadFactory,
             RejectedExecutionHandler handler){...
 
}

演示例子：

import static java.util.concurrent.Executors.newScheduledThreadPool;

import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;

/**
 * @author zhanghuilong
 * @version V1.0
 * @desc
 * @since 2018/01/05
 */
public class
 
 UserExecutors {
    private static volatile boolean result = false;

    static class TaskJob extends Thread{

        @Override
        public void run() {
            System.out.println("執行緒開始...執行任務");
        }
    }
    public static void main(String[] args) {
        // 1 建立一個任務實現執行緒介面
        TaskJob taskJob=new TaskJob();
        // 2 宣告2具有定時作用的執行緒池
        ScheduledExecutorService scheduledExecutorService = newScheduledThreadPool(1);
        // 3 執行job,啟動延遲10秒後開始執行，每隔5分鐘執行一次任務。。
        ScheduledFuture<?> scheduledFuture = scheduledExecutorService
            .scheduleWithFixedDelay(taskJob, 10, 5, TimeUnit.SECONDS);
    }

}