2. 程式人生 > 實用技巧 >Java執行緒排程

Java執行緒排程

阿新 • • 發佈：2020-12-29 
package com.wkcto.chapter07.method;
/**
 * 執行緒優先順序
 * 	1) 優先順序的取值範圍: 1 ~ 10
 * 	2) 所有執行緒預設的優先順序; 5
 * 	3) 優先順序越高, 獲得CPU執行權的機率越大
 * 	4) t1.setPriority( 10 )  設定執行緒優先順序
 * @author 蛙課網
 *
 */
public class Test04 {

	public static void main(String[] args) {
		Thread t1 = new Thread(new Runnable() {
			@Override
			public void run() {
				for(int i = 1; i <= 100; i++){
					System.out.println( Thread.currentThread().getName() + "-->" + i);
				}
			}
		} , "t1");
		t1.setPriority(1); 				//設定優先順序
		t1.start();
		
		Thread t2 = new Thread(new Runnable() {
			@Override
			public void run() {
				for(int i = 1; i <= 100; i++){
					System.out.println( Thread.currentThread().getName() + "-->" + i);
				}
			}
		} , "t2");
		t2.setPriority(10); 		//設定優先順序
		t2.start();
		
		//列印執行緒的優先順序
		System.out.println( "t1 priority: " + t1.getPriority());
		System.out.println( "t2 priority: " + t2.getPriority());
		System.out.println( "main priority: " + Thread.currentThread().getPriority());
		
		//main執行緒
		for(int i = 1; i <= 100; i++){
			System.out.println( Thread.currentThread().getName() + "-->" + i);
		}
	}

}

Java執行緒睡眠

package com.wkcto.chapter07.method;
/**
 * 執行緒睡眠 ( 休眠 )
 * 	 Thread.sleep( 2000 );
 * 		1) 是靜態方法, 通過Thread類名直接呼叫
 * 		2) 睡眠的單位 是毫秒, 1秒 == 1000 毫秒
 * 		3) sleep()有受檢異常需要預處理
 * 		4) sleep()方法所在的執行緒睡眠 
 * @author 蛙課網
 *
 */
public class Test05 {

	public static void main(String[] args) {
		Thread t1 = new Thread(new Runnable() {
			@Override
			public void run() {
				for( int i = 1 ; i<=100; i++){
					System.out.println( Thread.currentThread().getName() + "--> " + i);
					//當 i == 50 時, 執行緒休眠
					if ( i == 50 ) {
						//run()是重寫了Runnable介面中run(),不能宣告丟擲異常,只能捕獲處理
						try {
							Thread.sleep(3000);			//睡眠3秒
						} catch (InterruptedException e) {
							e.printStackTrace();
						}
					}
				}
			}
		}, "t1");
		t1.start();
		
//		t1 = null;
		//main執行緒
		for( int i = 1 ; i<=100; i++){
			System.out.println( Thread.currentThread().getName() + "-----> " + i);
			//當i==10時, 讓t1執行緒睡眠 
			/*try {
				t1.sleep(3000); 		//雖然是t1呼叫,實際上是main執行緒睡眠 
			} catch (InterruptedException e) {
				e.printStackTrace();
			}*/
		}
		
		System.out.println( t1.getState() );  		//TIMED_WAITING , t1處於sleep()睡眠 狀態
	}

}

Java執行緒中斷

package com.wkcto.chapter07.method;
/**
 * 執行緒中斷
 * 		t1.interrupt();		中斷t1執行緒
 * 		一般是把處於睡眠 / 等待中的執行緒給喚醒 
 * 
 * @author 蛙課網
 *
 */
public class Test06 {

	public static void main(String[] args) {
		Thread t1 = new Thread(new Runnable() {
			@Override
			public void run() {
				for( int i = 1 ; i<=100; i++){
					System.out.println( Thread.currentThread().getName() + "--> " + i);
					//當 i == 50 時, 執行緒休眠
					if ( i == 50 ) {
						try {
							Thread.sleep(10000);			//睡眠10秒
						} catch (InterruptedException e) {
//							e.printStackTrace();
						}
					}
				}
			}
		}, "t1");
		t1.start();
		
		//main執行緒
		for( int i = 1 ; i<=100; i++){
			System.out.println( Thread.currentThread().getName() + "--> " + i);
		}
		
		//當main執行緒結束 , 把t1執行緒喚醒
		t1.interrupt();  		//中斷t1執行緒的睡眠, 會丟擲中斷異常
		
//		System.out.println( t1.isInterrupted() );
	}

}
 

package com.wkcto.chapter07.method;
/**
 * 判斷執行緒的中斷狀態
 * 		t1.isInterrupted(), 例項方法判斷執行緒的中斷狀態, 返回true後,不會清除執行緒的中斷標誌
 * 		Thread.interrupted(), 靜態方法判斷執行緒的中斷狀態, 如果返回true表示執行緒被中斷了, 然後會清除執行緒的中斷標誌
 * 				再判斷執行緒的中斷狀態時, 就是false
 * @author 蛙課網
 *
 */
public class Test07 {

	public static void main(String[] args) {
		Thread t1 = new Thread(new Runnable() {
			@Override
			public void run() {
//				如果執行緒沒有被中斷,就一直列印字串
				while( ! Thread.currentThread().isInterrupted() ){
					System.out.println( "wkcto");
				}
				System.out.println("11 : " + Thread.currentThread().isInterrupted()); 
			}
		});
		t1.start();
		
		Thread t2 = new Thread(new Runnable() {
			@Override
			public void run() {
//				如果執行緒沒有被中斷,就一直列印字串
				while( ! Thread.interrupted() ){
					System.out.println( "bjpowernode");
				}
				System.out.println("22 : " + Thread.currentThread().isInterrupted()); 
			}
		});
		t2.start();
		
		// main執行緒
		for (int i = 1; i <= 50; i++) {
			System.out.println(Thread.currentThread().getName() + "--> " + i);
		}
		
		//main執行緒結束, 就中斷t1執行緒
		t1.interrupt();
		t2.interrupt();
	}

}

Java執行緒讓步

package com.wkcto.chapter07.method;
/**
 * 執行緒讓步
 * 		Thread.yield(); 
 * 		把執行中的執行緒轉換為就緒狀態
 * @author 蛙課網
 *
 */
public class Test08 {

	public static void main(String[] args) {
		Thread t1 = new Thread(new Runnable() {
			@Override
			public void run() {
				for (int i = 1; i <= 100; i++) {
					System.out.println(Thread.currentThread().getName() + "--> " + i);
					//當 i的值是10的倍數時, 執行緒讓步
					if ( i % 10 == 0) {
						Thread.yield();  	//轉換為就緒狀態
					}
				}
			}
		} , "t1");
		t1.start();
		
		Thread t2 = new Thread(new Runnable() {
			@Override
			public void run() {
				for (int i = 1; i <= 100; i++) {
					System.out.println(Thread.currentThread().getName() + "-====> " + i);
				}
			}
		} , "t2");
		t2.start();
	}

}

Java執行緒合併

package com.wkcto.chapter07.method;
/**
 * 執行緒合併
 * 		t1.join();  	在當前執行緒中加入t1執行緒,當前執行緒轉為等待狀態, 等到t1執行緒執行完畢後,當前執行緒再轉為就緒狀態
 * @author 蛙課網
 *
 */
public class Test09 {

	public static void main(String[] args) {
		Thread t1 = new Thread(new Runnable() {
			@Override
			public void run() {
				for (int i = 1; i <= 100; i++) {
					System.out.println(Thread.currentThread().getName() + "--> " + i);
				}
			}
		} , "t1");
		t1.start();
		
		Thread t2 = new Thread(new Runnable() {
			@Override
			public void run() {
				for (int i = 1; i <= 100; i++) {
					System.out.println(Thread.currentThread().getName() + "-====> " + i);
					//當i==10時, 把t1執行緒合併進來
					if ( i == 10 ) {
						try {
//							t1.join();   	//現在加入t1執行緒,  當前執行緒轉為等待狀態, 等到t1執行完後,t2當前執行緒再轉為就緒狀態
							t1.join(1000);  //如果當前執行緒等待1000毫秒後, 不管t1執行緒是否結束 ,都會轉為就緒狀態
						} catch (InterruptedException e) {
							e.printStackTrace();
						} 		
					}
				}
			}
		} , "t2");
		t2.start();
	}

}

Java執行緒終止

package com.wkcto.chapter07.method;
/**
 * 終止執行緒
 * 	相辦法讓run()結束 
 * 	可以為執行緒設計一個布林標誌, 在run()方法中定期判斷這個標誌,來決定是否結束 run()
 * @author 蛙課網
 *
 */
public class Test11 {

	public static void main(String[] args) {
		SubThread1 thread1 = new SubThread1();
		thread1.start();
		
		Prime3 prime3 = new Prime3();
		Thread t2 = new Thread(prime3);
		t2.start();
		
		//main執行緒
		for (int i = 1; i <= 50; i++) {
			System.out.println(Thread.currentThread().getName() + "========> " + i);
		}
		//main執行緒結束 , 終止t1執行緒
		thread1.stopping = true;
		prime3.running = false;
	}

}

class SubThread1  extends Thread{
	boolean stopping = false;
	@Override
	public void run() {
		for (int i = 1; i <= 500; i++) {
			if (stopping) {
				return; 			//結束方法的執行
			}
			System.out.println(Thread.currentThread().getName() + "--> " + i);
		}
	}
}

class Prime3 implements Runnable{
	boolean running = true;
	@Override
	public void run() {
		for( int i = 1; running && i<=500; i++){
			System.out.println(Thread.currentThread().getName() + "--> " + i);
		}
	}
}

相關推薦

Java執行緒排程

package com.wkcto.chapter07.method; /** * 執行緒優先順序 *1) 優先順序的取值範圍: 1 ~ 10

Java多執行緒(二)執行緒排程

Java多執行緒(二) 1.執行緒的生命週期及狀態轉換 六種狀態： NEW(新建狀態):建立一個執行緒後，該執行緒物件就處於新建狀態，此時它不能執行，僅僅由JVM為其分配了記憶體，沒有表現出任何執行緒的動態特徵。

Java基礎——執行緒排程

一、執行緒的兩種排程模型： 1.分時排程模型：所有執行緒輪流使用CPU的使用權，平均分配每個執行緒佔用CPU的時間片

Java執行緒池原理與原始碼詳細解讀，再也不怕面試問執行緒池了！

執行緒池 “執行緒池”，顧名思義就是一個執行緒快取，執行緒是稀缺資源，如果被無限制的建立，不僅會消耗系統資源，還會降低系統的穩定性，因此Java中提供執行緒池對執行緒進行統一分配、調優和監控。

通過這六點，瞭解Java執行緒池的全面（總結上篇）

目錄 一 使用執行緒池的好處 二 Executor 框架 三 (重要)ThreadPoolExecutor 類簡單介紹

工作常用4種Java執行緒鎖的特點，效能比較、使用場景

多執行緒的緣由 在出現了程式之後，作業系統的效能得到了大大的提升。雖然程式的出現解決了作業系統的併發問題，但是人們仍然不滿足，人們逐漸對實時性有了要求。

Java執行緒狀態

0 執行緒狀態概述 分類 6個狀態定義: java.lang.Thread.State New: 尚未啟動的執行緒的執行緒狀態。

簡單說說Java執行緒池

1 Java執行緒池簡介 Java1.5大師Doug Lea的作品。執行緒池能夠對執行緒進行統一的分配，通過固定數量的執行緒來負責處理任務，避免了頻繁的建立和銷燬物件，使執行緒能夠重複的利用，執行多個任務。

瞭解Java執行緒優先順序，更要知道對應作業系統的優先順序，不然會踩坑

Java 多執行緒系列第 6 篇。 這篇我們來看看 Java 執行緒的優先順序。 Java 執行緒優先順序

Java執行緒生命週期與狀態切換

前提 最近有點懶散，沒什麼比較有深度的產出。剛好想重新研讀一下JUC執行緒池的原始碼實現，在此之前先深入瞭解一下Java中的執行緒實現，包括執行緒的生命週期、狀態切換以及執行緒的上下文切換等等。編寫本文的時候

java執行緒

概述 相關關係： 程式：可理解為一組靜態程式碼。 程式：正在進行的程式(靜態的程式碼，執行起來)。

Java執行緒池最佳實踐

引言 在日常的開發工作當中，執行緒池往往承載著一個應用中最重要的業務邏輯，因此我們有必要更多地去關注執行緒池的執行情況，包括異常的處理和分析等等。本文主要聚焦在如何正確使用執行緒池上，以及提供一些實用的

Java執行緒生命週期和鎖的簡單使用

本文介紹了java執行緒的生命週期，Synchronized的幾個方法簡單的使用。 執行緒生命週期

深入學習java執行緒池

我們都是通過new Thread來建立一個執行緒，由於執行緒的建立和銷燬都需要消耗一定的CPU資源，所以在高併發下這種建立執行緒的方式將嚴重影響程式碼執行效率。而執行緒池的作用就是讓一個執行緒執行結束後不馬上銷燬，

圖解Java執行緒池原理

什麼是執行緒池？ 為了避免頻繁重複的建立和銷燬執行緒，我們可以讓這些執行緒進行復用，線上程池中，總會有活躍的執行緒在佔用，但是執行緒池中也會存在沒有佔用的執行緒，這些執行緒處於空閒狀態，當有任務的時候會

java執行緒變數那點事兒

寫在前面 該文章主要介紹ThreadLocal以及其變種，所以執行緒的方法、執行緒池、以及涉及執行緒方法的一些變數不在該文章講解；

Java執行緒狀態執行原理解析

這篇文章主要介紹了Java執行緒狀態執行原理解析,文中通過示例程式碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下

如何實現Java執行緒安全問題

這篇文章主要介紹瞭如何實現Java執行緒安全問題,文中通過示例程式碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下

Java執行緒死鎖例項及解決方法

這篇文章主要介紹了Java執行緒死鎖例項及解決方法,文中通過示例程式碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下

Java執行緒併發訪問程式碼分析

這篇文章主要介紹了Java執行緒併發訪問程式碼分析,文中通過示例程式碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下