通過整合Thread類實現多執行緒

package TreadLearning;

/**
 * 建立執行緒方法1
 * 利用繼承Thread類+重寫run方法
 * new物件然後呼叫start（）方法（不能直接呼叫run方法）
 * @author 袁盛桐
 *
 */
public class TreadExtend extends Thread{

	@Override
	public void run() {
		for(int i=0; i<100; i++) {
			System.out.println("A"+i);
		}
	}
	
	public static void main(String[] args) {
		TreadExtend a = new TreadExtend();
		TreadExtend2 b = new TreadExtend2();
		a.start();
		b.start();
	}
}

class TreadExtend2 extends Thread{

	@Override
	public void run() {
		for(int i=0; i<100; i++) {
			System.out.println("B"+i);
		}
	}
	
	
}
 

重寫runable介面建立多執行緒 

package TreadLearning;

/**
 * 建立執行緒方法2
 * 1.實現runnable介面+重寫run方法
 * 2.啟動多執行緒 使用靜態代理
 *   (1)建立真實角色
 *   (2)建立代理角色+真實角色引用
 *   (3)呼叫start()來啟動執行緒
 *   
 *好處(1)避免單繼承的侷限性
 * (2)便於共享資源
 * @author 袁盛桐
 *
 */
public class ThreadImpRunable implements Runnable{

	@Override
	public void run() {
		for(int i=0; i<100; i++) {
			System.out.println("A"+i);
		}
	}
	
	public static void main(String[] args) {
		//(1)建立真實角色
		ThreadImpRunable demo = new ThreadImpRunable();
		//(2)建立代理角色+真實角色引用
		Thread proxy = new Thread(demo);
		//(3)呼叫start()來啟動執行緒
		proxy.start();//成為其中一條執行緒路徑
		
		for(int i=0; i<100; i++) {
			System.out.println("B"+i);
		}
	}
}
 

重寫callable介面建立多執行緒

package TreadLearning;

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

public class Call {
	public static void main(String[] args) throws InterruptedException, ExecutionException {
		//建立執行緒
		ExecutorService ser =Executors.newFixedThreadPool(1);
		ThreadImpCallable demo = new ThreadImpCallable();
		//獲取值
		Future<Integer> result = ser.submit(demo);
		int num = result.get();
		System.out.println(num);
		//停止服務
		ser.shutdownNow();
	}
}

class ThreadImpCallable implements Callable<Integer>{
	
	@Override
	public Integer call() throws Exception {
		return 1000;
	}

}