一、建立執行緒： 

package com.dong.testThread;
/**
 * 
 * 1.執行緒的建立
 * 2.執行緒的方法
 * 
 * @author liuD
 *
 */
public class MultiThread {
	public static void main(String[] args) throws InterruptedException {
		//建立執行緒1，使用實現Runnable介面的類，使用lambda表示式；
		Thread  trl =new Thread(() -> System.out.println(Thread.currentThread().getName()+ " thread start..."));
		trl.start();
		//使用實現Runnable介面的類，不使用lambda表示式；
		Thread tr = new Thread(new runnableExam());
		tr.start();
		//建立執行緒2，使用繼承了Thread類來建立執行緒,使用預設的run()
		Thread th = new Thread();
		th.start();
		//建立執行緒3，使用繼承了Thread類的例項做引數。使用重寫的run()
		Thread th2 =new Thread(new threadExam());
		
	}
}
class threadExam extends Thread{
	public void run() {
		System.out.println(Thread.currentThread().getName()+ " thread2 start ...");
	}
}
class runnableExam implements Runnable{
	@Override
	public void run() {
		System.out.println(Thread.currentThread().getName()+ " thread start ...");
	}
	
}
 

二、執行緒的各個狀態：

⑴新建： new()

package com.dong.testThread;
/**
 * 執行緒的new狀態，即剛建立的執行緒
 * @author liuD
 */
public class TestNew {
	public static void main(String[] args) {
		//使用lambda建立執行緒；
		Thread t = new Thread(
				() -> System.out.println(Thread.currentThread().getName() + " will running")
				);
	}
}

 

⑵睡眠：sleep()

package com.dong.testThread;
/**
 * 測試Sleep功能，Sleep是讓執行緒等待million毫秒後在執行
 * @author liuD
 */
public class TestSleep extends Thread{
	StringBuilder str = new StringBuilder();
	public static void main(String[] args) throws InterruptedException {
		Thread thread = new Thread(new TestSleep());
		long startTime  = System.currentTimeMillis();
		//⑵執行緒睡眠2秒
		thread.sleep(2000);
		long sleepTime  = System.currentTimeMillis();
		//注意這個結果不一定是2000
		System.out.println("thread has sleep "+ (sleepTime - startTime )+ " finish and will start ");
		thread.start();
	}
	public void run(){
		for(int i = 0 ;i< 10;i++) {
			str.append(".");
			System.out.println(str.toString());
		}
	}
}
 

⑶停止：stop()  （不建議使用）

package com.dong.testThread;
/**
 * 測試stop方法，stop方法會立刻釋放鎖資源，可能導致資料的不一致；
 * 
 * @author liuD
 *
 */
public class testStop {
	public static void main(String[] args) throws InterruptedException {
		new ReadObjectThread().start();
		while(true) {
			Thread t = new ChangeObjectThread();
			t.start();
			Thread.sleep(100);
			//呼叫stop()方法；
			t.stop();
		}
	}
}
class User{
	static int a = 0;
	static int b = 0;
	
	public static int getA() {
		return a;
	}
	public static int getB() {
		return b;
	}
	public static void setA() {
		a = a + 1;
	}
	public static void steB() {
		b = b + 1;
	}
}
class  ChangeObjectThread extends Thread{
	public  void run() {
		while(true) {
			synchronized(User.class) {
				User.setA();
				try {
					Thread.sleep(10);
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
				User.steB();
			}
			Thread.yield();
		}
	}
}
class ReadObjectThread extends Thread{
	public void run() {
		while(true) {
			synchronized(User.class) {
				if(User.getA() != User.getB()) {
					System.out.println( "A = "+  User.getA() + " B = " + User.getB());
				}
			}
			Thread.yield();
		}
	}
}

⑷中斷：interrupte()

package com.dong.testThread;
/**
 * 測試interrupte()方法
 * 當呼叫interrupte()方法，會給執行緒傳送一個通知，告訴目標執行緒，該退出，至於如何退出，有目標執行緒自行決定；
 * interrrupte會通知目標執行緒中斷，也就是設定中斷標誌位，中斷標誌位表示當前執行緒已經被中斷了。
 * 剛呼叫interrupte()方法，相當於只設置了中斷標誌，但是這個中斷不會發生任何作用；
 *如果想顯示終止執行緒，可以使用Thread.currentThread().isInterrupted()方法，判斷執行緒是否已經中斷，可以顯式中斷執行緒；
 * @author liuD
 *
 */
public class TestInterrupt {
	public static void main(String[] args) throws InterruptedException {
		Thread thread = new Thread(new TThread());
		thread.start();
		thread.sleep(2000);
		//執行緒的中斷不確定，設定了中斷標誌
		thread.interrupt();
		
		Thread tot = new Thread(new ToThread());
		tot.start();
		//執行緒的中斷不確定，只是設定了中斷標誌
		tot.interrupt();
	}
}
class TThread implements Runnable{
	@Override
	public void run() {
		while(true) {
			//判斷執行緒是否被中斷，顯式中斷執行緒的執行；
			if(Thread.currentThread().isInterrupted()) {
				System.out.println(" Interrupted !!! ");
				break;
			}
			System.out.println("TT -----this is thread ...");
		}
		Thread.yield();
	}
}
class ToThread implements Runnable {
	@Override
	public void run() {
		// TODO Auto-generated method stub
		while(true) {
			System.out.println("ToT-----this is thread ...");
		}
	}
	
}

⑸等待：wait()   

⑹喚醒：notify()

package com.dong.testThread;
/**
 * wait()方法和notify()方法是在object類中定義的，
 * wait()讓當然執行緒等待，進入鎖物件的等待佇列，直到有執行緒呼叫notify()方法，才會從等待佇列中隨機選擇一個等待執行緒進行喚醒，
 * notify()方法從等待佇列總隨機選擇一個執行緒進行喚醒；
 * @author liuD
 *
 */
public class TestWaitAndNotify {
	final static Object object = new Object();
	public static void main(String[] args) {
		Thread t1  = new Thread(new ToThreads());
		t1.start();
		Thread t2 = new Thread(new ToT2Threads());
		t2.start();
	}

static class ToThreads implements Runnable{
	@Override
	public void run() {
		synchronized (object) {
			System.out.println(System.currentTimeMillis()+ " : T1 start ");
			try {
				System.out.println(System.currentTimeMillis()+": T1 wait for object" );
				object.wait();
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			System.out.println(System.currentTimeMillis()+": T1 end !");
		}
	}	
}
static class ToT2Threads implements Runnable{
	public void run() {
		synchronized(object) {
			System.out.println(System.currentTimeMillis()+ " :T2 start notify one thread");
			object.notify();
			System.out.println(System.currentTimeMillis()+ " : T2 end! ");			
			try {
				Thread.sleep(2000);
			}catch(InterruptedException e) {}
		}
	}
	}
}

⑻謙讓：yield

package com.dong.testThread;
/**
 * yield()方法會讓當前執行緒讓出Cpu的執行權，停止執行，從而重新爭取cpu的資源，
 * @author liuD
 */
public class testYield {
	public static void main(String[] args) {
		Thread t1 = new Thread(new T1());
		Thread t2 = new Thread(new T2());
		//多個執行緒之間的執行是隨機的，因此使用yield()方法，看不出來謙讓的效果，所以設定一個高優先順序和低優先順序執行緒，來觀察yield()的效果
		t1.setPriority(10);
		t2.setPriority(1);
		t1.start();
		//可以註釋掉t1.yield()語句，來觀察輸出結果之間的變化；
		t1.yield();
		t2.start();
	}
}
class T1 implements Runnable{
	@Override
	public void run() {
		for(int i = 0;i<20;i++) {
			System.out.println("i \' am a brothers");
		}
	}
}
class T2 implements Runnable{
	@Override
	public void run() {
		// TODO Auto-generated method stub
		for(int j =0;j<20;j++) {
			System.out.println("I \' am a sister");
		}
	}
}

⑼加入：join

package com.dong.testThread;
/**
 * 
 * yield()方法，它會阻塞當前執行緒，直到目標執行緒執行完畢，
 * @author liuD
 */
public class TestJoin {
	public static void main(String[] args) throws InterruptedException {
		Thread t1 = new Thread(new joinThread());
		t1.start();
		//阻塞主執行緒，其他執行緒願意等待t1執行緒執行完畢在執行,這裡其他執行緒指主執行緒，如果沒有t1.join(),則兩個執行緒的輸出語句就會隨機輸出		
		t1.join();
		for(int i = 0 ;i< 1000;i++) {
			System.out.println(Thread.currentThread().getName() +" : " + i);
		}
	}
}
class joinThread implements Runnable{
	public void run() {
		for(int j = 0 ;j < 3;j++) {
		System.out.println(Thread.currentThread().getName()+ " :  start start start " );
		}
	}
}

⑽執行：start

就是建立執行緒後，啟動啟動執行緒的方法，threadObject.start()方法；

部分程式碼參考《Java 高併發程式設計》  --葛一鳴，郭超 ，，由衷感謝此書作者為我們提供學習內容