java多線程編程實例

㈠ 什麼是多線程編程

多線程編程技術是java語言的重要特點。多線程編程的含義是將程序任務分成幾個並行的子任務。特別是在網路編程中，你會發現很多功能是可以並發執行的。 比如網路傳輸速度較慢、用戶輸入速度較慢，你可以用兩個獨立的線程去完成這兩個功能，而不影響正常的顯示或其它功能。 多線程是與單線程比較而言的，普通的Windows採用單線程程序結構，其工作原理是：主程序有一個消息循環，不斷從消息隊列中讀入消息來決定下一步所要乾的事情，一般是針對一個函數，只有等這個函數執行完之後，主程序才能接收另外的消息來執行。比如子函數功能是在讀一個網路數據，或讀一個文件，只有等讀完這個數據或文件才能接收下一個消息。在執行這個子函數過程中你什麼也不能幹。但往往讀網路數據和等待用戶輸入有很多時間處於等待狀態，多線程利用這個特點將任務分成多個並發任務後，就可以解決這個問題。Java中的線程類 1.擴展java.lang.Thread類，用它覆蓋Thread類的run方法。 2.生成實現java.lang.Runnable介面的類並將其它的實例與java.lang.Thread實例相關聯。 Thread類是負責向其它類提供線程支持的最主要的類，要使用一個類具有線程功能，在Java中只要簡單地從Thread類派生一個子類就可以了擴展Thread類，如printThread.java。 Thread類最重要的方法是run方法。run方法是新線程執行的方法，因此生成java.lang.Thread的子類時，必須有相應的run方法。 //PrintThread.java public class PrintThread extends Thread//繼承Tread類 private int count=0 //定義一個count變數用於統計列印的次數並共享變數 public static void mainString args//main方法開始 PrintThread p=new PrintThread//創建一個線程實例 p.start//執行線程 for{;;}//主線程main方法執行一個循環，for執行一個死循環count++ System.out.printcount+″：Main\n″//主線程中列印count +「main」變數的值，並換行 public void run//線程類必須有的run（）方法for{;;}count++ System.out.printcount+″：Thread\n″ 上面這段程序便是繼承java.lang.Tread並覆蓋run的方法。用Java 虛擬機啟動程序時，這個程序會先生成一個線程並調用程序主類的main方法。這個程序中的main方法生成新線程，連接列印「Thread」。在啟動線程之後，主線程繼續列印「Main」。 編譯並執行這個程序，然後立即按「Ctrl+C」鍵中斷程序，你會看到上面所述的兩個線程不斷列印出：XXX：main…..XXX：Thread…. XXX代表的是數字，也就是上面count的值。在筆者的機器上，不同時刻這兩個線程列印的次數不一樣，先列印20個main（也就是先執行20次主線程）再列印出50次Thread，然後再列印main…… 提示：為了便於查看該程序的執行結果，你可以將執行結果導入一個文本文件，然後打開這個文件查看各線程執行的情況。如運行： javac PrintThread.java Java PrintThread1.txt 第一個命令javac PrintThread.java是編譯java程序，第二個是執行該程序並將結果導入1.txt文件。當然你可以直接執行命令：java

㈡ 璇劇▼璁捐￠樼洰錛屽氱嚎紼嬬紪紼嬶細鍖婚櫌闂ㄨ瘖妯℃嫙錛屾兂鐢╦ava瀹炵幇錛屾眰澶х炴寚鐐

鍏稿瀷鐨勭敓浜ц呮秷璐硅呮ā鍨嬨

浜嗚Вj5鐨勫苟鍙戝簱錛岄偅涓騫跺彂搴撲腑鏈夐傚悎緇勪歡瀹炵幇銆

濡傛灉涓嶄簡瑙ｏ紝榪欎箞鏉ワ細

鍒涘緩涓涓闃熷垪錛屾ら槦鍒楄佹眰綰跨▼瀹夊叏錛屽傛灉闃熷垪涓虹┖鍒欐秷璐硅呴樆濉炪傚傛灉闃熷垪杈懼埌鏌愪釜鏈澶у礆紝鍒欓樆濉炵敓浜ц呫

闃熷垪鐢錛屾櫘閫氱殑list鎴栧疄鐜板ソ鐨勯槦鍒楀寘瑁呮垚綰跨▼瀹夊叏鐨勩

鐢╯ynchronized鍚屾ュ師鏂規硶鎴栦唬鐮佸潡銆

鍐欎竴涓鎴杗涓綰跨▼錛屾ā鎷熺棶浜猴紝鎺掗槦鍔炵悊涓氬姟錛屽線涓婇潰鐨勯槦鍒椾腑娣誨姞鏁版嵁銆

褰撹揪鍒伴槦鍒楃殑鏈澶у圭Н錛岄樆濉烇紝絳夊緟鐢熶駭鑰呯嚎紼嬪彇鏁版嵁銆

闃誨烇細makerLock.wait();//鉶氭嫙鏈轟細鍑鴻╃嚎紼嬫寕璧鳳紝鍏跺疄灝辨槸鎿嶄綔緋葷粺錛屼繚瀛樺綋鍓嶇嚎紼嬪湪cpu涓婄殑榪愯岀姸鎬併傚啀鍑鴻╃嚎紼嬫ｅ湪浣跨敤鐨刢pu璧勬簮錛屽崰鐢ㄧ殑鍐呭瓨涓嶄細閲婃斁銆

寰闃熷垪鎻掑叆鏁版嵁鐨勬椂鍊欙紝鍥犱負涓嶇煡閬撴槸鍚︽湁娑堣垂鑰呭勪簬絳夊緟鐘舵侊紝閫氱煡娑堣垂鑰咃細

customerLock.notifyAll();//鉶氭嫙鏈鴻皟搴︽秷璐硅呯嚎紼嬭繍琛岋紝瀹為檯涓婃槸鎿嶄綔緋葷粺錛屾妸淇濆瓨鐨勬秷璐硅呯嚎紼嬬姸鎬侊紝浠庢柊鍔犺澆鍒癱pu涓鎺ョ潃榪愯屻傛帴鐫榪愯岀嚎紼嬫槸浠繪剰鐨勶紝鍙栧喅浜庝笉鍚屾搷浣滅郴緇熺殑綰跨▼璋冨害綆楁硶銆

娑堣垂鑰呯嚎紼嬭誨彇涓涓鏁版嵁鍚庯紝瑕侀氱煡鐢熶駭鑰咃紝鍙浠ョ戶緇錛岄亾鐞嗗悓涓婏細

makerLock.notifyAll();

闃熷垪涓錛屾棤鏁版嵁鍙璇葷殑鏃跺欙細

customerLock.wait();//鍘熺悊鍚屼笂錛

鏈鍚庢敞鎰忥紝鐢熶駭鑰呰窡娑堣垂鑰呬嬌鐢ㄤ簡涓や釜涓嶅悓鐨勫硅薄閿併俵ock.wait()鐨勪嬌鐢ㄦ柟娉曟槸榪欐牱鐨勶細

synchronized(lock){

......

while(condition==true){

lock.wait();

}

......

Objecto=queen.pop();

lock.notifyAll();

}

鏈鍚庡惎鍔╪涓綰跨▼璇婚槦鍒楋紝妯℃嫙鍔炵悊涓氬姟鐨勭獥鍙ｏ紱n涓綰跨▼鍐欓槦鍒楋紝妯℃嫙鐥呬漢鎺掗槦銆

鏂扮嚎紼嬪簱涔熸湁璺熻佺嚎紼嬪簱瀵瑰簲鐨勬柟娉曪紝鏂扮嚎紼嬪簱鏈夌嚎紼嬪畨鍏ㄧ殑楂樻晥闃熷垪銆傛病鏈変笂闈㈤夯鐑︼紝浣嗕笂闈㈠啓鐨勬槸鐞嗚В鏂扮嚎紼嬫暟鎹緇撴瀯涓庡疄鐜扮殑鍩虹銆

packagecom.;

importjava.util.LinkedList;
importjava.util.List;
importjava.util.Random;

publicclassTestThread2{
	
	//緙撳啿涓婇檺
	privatelongbufsize;
	
	//緙撳啿
	privateList<String>buf;
	
	publicTestThread2(){
		bufsize=5;
		buf=newLinkedList<String>();
	}
	
	//鐢熶駭鑰呰皟鐢
	publicvoidput(Strings){
		//妯℃嫙鐢熶駭鑰呰窡涓嶄笂娑堣垂鑰
		/*
		try{
			Thread.sleep(100);
		}catch(InterruptedExceptione){
		}
		*/
		
		synchronized(this){
			//瓚呰繃闃熷垪闄愬埗灝辯瓑寰
			while(buf.size()==bufsize){
				System.out.println("闃熷垪宸叉弧錛岀敓浜ц:"+Thread.currentThread().getId()+"寮濮嬬瓑寰呫");
				try{
					this.wait();
				}catch(InterruptedExceptione){
				}
			}

			buf.add(s);
			
			//閫氱煡娑堣垂鑰
			this.notifyAll();
		}
		
	}
	
	//娑堣垂鑰呰皟鐢
	synchronizedpublicStringtake(){
		
		//妯℃嫙娑堣垂鑰呰窡涓嶄笂鐢熶駭鑰	
		try{
			Thread.sleep(100);
		}catch(InterruptedExceptione){
		}
		
		Strings=null;
		
		synchronized(this){
			while(buf.size()==0){
				System.out.println("闃熷垪涓虹┖錛屾秷璐硅:"+Thread.currentThread().getId()+"寮濮嬬瓑寰呫");
				try{
					this.wait();
				}catch(InterruptedExceptione){
				}
			}
			
			//鍙栧厛鏀懼叆鐨勫厓緔狅紝騫剁Щ闄
			s=buf.get(0);
			buf.remove(0);
			
			//閫氱煡鐢熶駭鑰
			this.notifyAll();
		}
				
		returns;
	}

	publicstaticvoidmain(String[]args){
		//鑷宸卞疄鐜扮殑錛屽畨鍏ㄩ槦鍒
		finalTestThread2tt=newTestThread2();
		
		//鐢熶駭鑰
		Threadp=newThread(newRunnable(){

			@Override
			publicvoidrun(){
				while(!Thread.currentThread().isInterrupted()){
					Randomr=newRandom();
					tt.put(String.valueOf(r.nextInt(10)));
				}
			}
			
		});
		
		//娑堣垂鑰
		Threadc1=newThread(newRunnable(){

			@Override
			publicvoidrun(){
				while(!Thread.currentThread().isInterrupted()){
					System.out.println("綰跨▼錛"+Thread.currentThread().getId()+"鑾峰彇鍒版暟鎹"+tt.take());
				}
			}
			
		});
		
		Threadc2=newThread(newRunnable(){

			@Override
			publicvoidrun(){
				while(!Thread.currentThread().isInterrupted()){
					System.out.println("綰跨▼錛"+Thread.currentThread().getId()+"鑾峰彇鍒版暟鎹"+tt.take());
				}
			}
			
		});
		
		p.start();
		c1.start();
		c2.start();
		
		try{
			p.join();
			c1.join();
			c2.join();
		}catch(InterruptedExceptione){
		}
		

	}

}