待續...

package com.dason.juc2;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

/*
 * 一、執行緒池：提供了一個執行緒佇列，佇列中儲存著所有等待狀態的執行緒。避免了建立與銷燬額外開銷，提高了響應的速度。
 * 
 * 二、執行緒池的體系結構：
 * 	java.util.concurrent.Executor : 負責執行緒的使用與排程的根介面
 * 		|--**ExecutorService 子介面: 執行緒池的主要介面
 * 			|--ThreadPoolExecutor 執行緒池的實現類
 * 			|--ScheduledExecutorService 子介面：負責執行緒的排程
 * 				|--ScheduledThreadPoolExecutor ：繼承 ThreadPoolExecutor， 實現 ScheduledExecutorService
 * 
 * 三、工具類 : Executors 
 * ExecutorService newFixedThreadPool() : 建立固定大小的執行緒池
 * ExecutorService newCachedThreadPool() : 快取執行緒池，執行緒池的數量不固定，可以根據需求自動的更改數量。
 * ExecutorService newSingleThreadExecutor() : 建立單個執行緒池。執行緒池中只有一個執行緒
 * 
 * ScheduledExecutorService newScheduledThreadPool() : 建立固定大小的執行緒，可以延遲或定時的執行任務。
 */
public class TestThreadPool {
	
	public static void main(String[] args) throws Exception {
//		//1. 建立執行緒池
		ExecutorService pool = Executors.newFixedThreadPool(5);
//		ThreadPoolDemo tpd = new ThreadPoolDemo();
//		
//		//2. 為執行緒池中的執行緒分配任務
//		for (int i = 0; i < 10; i++) {
//			pool.submit(tpd);
//		}
//		
//		//3. 關閉執行緒池
//		pool.shutdown();
		
		List<Future<Integer>> list = new ArrayList<>();
		
		for (int i = 0; i < 10; i++) {
			Future<Integer> future = pool.submit(new Callable<Integer>(){

				@Override
				public Integer call() throws Exception {
					int sum = 0;
					
					for (int i = 0; i <= 100; i++) {
						sum += i;
					}
					
					return sum;
				}
				
			});

			list.add(future);
		}
		
		pool.shutdown();
		
		for (Future<Integer> future : list) {
			System.out.println(future.get());
		}
		
	}
	

}

class ThreadPoolDemo implements Runnable{

	private int i = 0;
	
	@Override
	public void run() {
		while(i <= 100){
			System.out.println(Thread.currentThread().getName() + " : " + i++);
		}
	}
	
}
 

package com.dason.juc2;

import java.util.Random;
import java.util.concurrent.Callable;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

/*
 * 一、執行緒池：提供了一個執行緒佇列，佇列中儲存著所有等待狀態的執行緒。避免了建立與銷燬額外開銷，提高了響應的速度。
 * 
 * 二、執行緒池的體系結構：
 * 	java.util.concurrent.Executor : 負責執行緒的使用與排程的根介面
 * 		|--**ExecutorService 子介面: 執行緒池的主要介面
 * 			|--ThreadPoolExecutor 執行緒池的實現類
 * 			|--ScheduledExecutorService 子介面：負責執行緒的排程
 * 				|--ScheduledThreadPoolExecutor ：繼承 ThreadPoolExecutor， 實現 ScheduledExecutorService
 * 
 * 三、工具類 : Executors 
 * ExecutorService newFixedThreadPool() : 建立固定大小的執行緒池
 * ExecutorService newCachedThreadPool() : 快取執行緒池，執行緒池的數量不固定，可以根據需求自動的更改數量。
 * ExecutorService newSingleThreadExecutor() : 建立單個執行緒池。執行緒池中只有一個執行緒
 * 
 * ScheduledExecutorService newScheduledThreadPool() : 建立固定大小的執行緒，可以延遲或定時的執行任務。
 */
public class TestScheduledThreadPool {

	public static void main(String[] args) throws Exception {
		ScheduledExecutorService pool = Executors.newScheduledThreadPool(5);
		
		for (int i = 0; i < 5; i++) {
			Future<Integer> result = pool.schedule(new Callable<Integer>(){

				@Override
				public Integer call() throws Exception {
					int num = new Random().nextInt(100);//生成隨機數
					System.out.println(Thread.currentThread().getName() + " : " + num);
					return num;
				}
				
			}, 1, TimeUnit.SECONDS);
			
			System.out.println(result.get());
		}
		
		pool.shutdown();
	}
	
}