10 目錄(?)[-] 11 一擴展javalangThread類 12 二實現javalangRunnable接口 13 三Thread和Runnable的區別 14 四線程狀態轉換 15 五線程調度 16 六常用函數說明 17 使用方式 18 為什么要用join方法 19 七常見線程名詞解釋 20 八線程同步 21 九線程數據傳遞 22 本文主要講了java中多線程的使用方法、線程同步、線程數據傳遞、線程狀態及相應的一些線程函數用法、概述等。 23 24 首先講一下進程和線程的區別: 25 26 進程:每個進程都有獨立的代碼和數據空間(進程上下文),進程間的切換會有較大的開銷,一個進程包含1--n個線程。 27 28 線程:同一類線程共享代碼和數據空間,每個線程有獨立的運行棧和程序計數器(PC),線程切換開銷小。 29 30 線程和進程一樣分為五個階段:創建、就緒、運行、阻塞、終止。 31 32 多進程是指操作系統能同時運行多個任務(程序)。 33 34 多線程是指在同一程序中有多個順序流在執行。 35 36 在java中要想實現多線程,有兩種手段,一種是繼續Thread類,另外一種是實現Runable接口。 37 38 一、擴展java.lang.Thread類 39 40 package com.multithread.learning; 41 /** 42 *@functon 多線程學習 43 *@author 林炳文 44 *@time 2015.3.9 45 */ 46 class Thread1 extends Thread{ 47 private String name; 48 public Thread1(String name) { 49 this.name=name; 50 } 51 public void run() { 52 for (int i = 0; i < 5; i++) { 53 System.out.println(name + "運行 : " + i); 54 try { 55 sleep((int) Math.random() * 10); 56 } catch (InterruptedException e) { 57 e.printStackTrace(); 58 } 59 } 60 61 } 62 } 63 public class Main { 64 65 public static void main(String[] args) { 66 Thread1 mTh1=new Thread1("A"); 67 Thread1 mTh2=new Thread1("B"); 68 mTh1.start(); 69 mTh2.start(); 70 71 } 72 73 } 74 輸出: 75 A運行 : 0 76 B運行 : 0 77 A運行 : 1 78 A運行 : 2 79 A運行 : 3 80 A運行 : 4 81 B運行 : 1 82 B運行 : 2 83 B運行 : 3 84 B運行 : 4 85 86 再運行一下: 87 88 A運行 : 0 89 B運行 : 0 90 B運行 : 1 91 B運行 : 2 92 B運行 : 3 93 B運行 : 4 94 A運行 : 1 95 A運行 : 2 96 A運行 : 3 97 A運行 : 4 98 說明: 99 程序啟動運行main時候,java虛擬機啟動一個進程,主線程main在main()調用時候被創建。隨着調用MitiSay的兩個對象的start方法,另外兩個線程也啟動了,這樣,整個應用就在多線程下運行。 100 101 注意:start()方法的調用后並不是立即執行多線程代碼,而是使得該線程變為可運行態(Runnable),什么時候運行是由操作系統決定的。 102 從程序運行的結果可以發現,多線程程序是亂序執行。因此,只有亂序執行的代碼才有必要設計為多線程。 103 Thread.sleep()方法調用目的是不讓當前線程獨自霸占該進程所獲取的CPU資源,以留出一定時間給其他線程執行的機會。 104 實際上所有的多線程代碼執行順序都是不確定的,每次執行的結果都是隨機的。 105 106 但是start方法重復調用的話,會出現java.lang.IllegalThreadStateException異常。 107 108 Thread1 mTh1=new Thread1("A"); 109 Thread1 mTh2=mTh1; 110 mTh1.start(); 111 mTh2.start(); 112 113 輸出: 114 Exception in thread "main" java.lang.IllegalThreadStateException 115 at java.lang.Thread.start(Unknown Source) 116 at com.multithread.learning.Main.main(Main.java:31) 117 A運行 : 0 118 A運行 : 1 119 A運行 : 2 120 A運行 : 3 121 A運行 : 4 122 123 二、實現java.lang.Runnable接口 124 125 /** 126 *@functon 多線程學習 127 *@author 林炳文 128 *@time 2015.3.9 129 */ 130 package com.multithread.runnable; 131 class Thread2 implements Runnable{ 132 private String name; 133 134 public Thread2(String name) { 135 this.name=name; 136 } 137 138 @Override 139 public void run() { 140 for (int i = 0; i < 5; i++) { 141 System.out.println(name + "運行 : " + i); 142 try { 143 Thread.sleep((int) Math.random() * 10); 144 } catch (InterruptedException e) { 145 e.printStackTrace(); 146 } 147 } 148 149 } 150 151 } 152 public class Main { 153 154 public static void main(String[] args) { 155 new Thread(new Thread2("C")).start(); 156 new Thread(new Thread2("D")).start(); 157 } 158 159 } 160 輸出: 161 C運行 : 0 162 D運行 : 0 163 D運行 : 1 164 C運行 : 1 165 D運行 : 2 166 C運行 : 2 167 D運行 : 3 168 C運行 : 3 169 D運行 : 4 170 C運行 : 4 171 172 說明: 173 Thread2類通過實現Runnable接口,使得該類有了多線程類的特征。run()方法是多線程程序的一個約定。所有的多線程代碼都在run方法里面。Thread類實際上也是實現了Runnable接口的類。 174 在啟動的多線程的時候,需要先通過Thread類的構造方法Thread(Runnable target) 構造出對象,然后調用Thread對象的start()方法來運行多線程代碼。 175 實際上所有的多線程代碼都是通過運行Thread的start()方法來運行的。因此,不管是擴展Thread類還是實現Runnable接口來實現多線程,最終還是通過Thread的對象的API來控制線程的,熟悉Thread類的API是進行多線程編程的基礎。 176 三、Thread和Runnable的區別 177 178 如果一個類繼承Thread,則不適合資源共享。但是如果實現了Runable接口的話,則很容易的實現資源共享。 179 180 package com.multithread.learning; 181 /** 182 *@functon 多線程學習,繼承Thread,資源不能共享 183 *@author 林炳文 184 *@time 2015.3.9 185 */ 186 class Thread1 extends Thread{ 187 private int count=5; 188 private String name; 189 public Thread1(String name) { 190 this.name=name; 191 } 192 public void run() { 193 for (int i = 0; i < 5; i++) { 194 System.out.println(name + "運行 count= " + count--); 195 try { 196 sleep((int) Math.random() * 10); 197 } catch (InterruptedException e) { 198 e.printStackTrace(); 199 } 200 } 201 202 } 203 } 204 205 public class Main { 206 207 public static void main(String[] args) { 208 Thread1 mTh1=new Thread1("A"); 209 Thread1 mTh2=new Thread1("B"); 210 mTh1.start(); 211 mTh2.start(); 212 213 } 214 215 } 216 217 輸出: 218 B運行 count= 5 219 A運行 count= 5 220 B運行 count= 4 221 B運行 count= 3 222 B運行 count= 2 223 B運行 count= 1 224 A運行 count= 4 225 A運行 count= 3 226 A運行 count= 2 227 A運行 count= 1 228 229 從上面可以看出,不同的線程之間count是不同的,這對於賣票系統來說就會有很大的問題,當然,這里可以用同步來作。這里我們用Runnable來做下看看 230 231 /** 232 *@functon 多線程學習 繼承runnable,資源能共享 233 *@author 林炳文 234 *@time 2015.3.9 235 */ 236 package com.multithread.runnable; 237 class Thread2 implements Runnable{ 238 private int count=15; 239 @Override 240 public void run() { 241 for (int i = 0; i < 5; i++) { 242 System.out.println(Thread.currentThread().getName() + "運行 count= " + count--); 243 try { 244 Thread.sleep((int) Math.random() * 10); 245 } catch (InterruptedException e) { 246 e.printStackTrace(); 247 } 248 } 249 250 } 251 252 } 253 public class Main { 254 255 public static void main(String[] args) { 256 257 Thread2 my = new Thread2(); 258 new Thread(my, "C").start();//同一個mt,但是在Thread中就不可以,如果用同一個實例化對象mt,就會出現異常 259 new Thread(my, "D").start(); 260 new Thread(my, "E").start(); 261 } 262 263 } 264 265 輸出: 266 C運行 count= 15 267 D運行 count= 14 268 E運行 count= 13 269 D運行 count= 12 270 D運行 count= 10 271 D運行 count= 9 272 D運行 count= 8 273 C運行 count= 11 274 E運行 count= 12 275 C運行 count= 7 276 E運行 count= 6 277 C運行 count= 5 278 E運行 count= 4 279 C運行 count= 3 280 E運行 count= 2 281 282 這里要注意每個線程都是用同一個實例化對象,如果不是同一個,效果就和上面的一樣了! 283 284 總結: 285 286 實現Runnable接口比繼承Thread類所具有的優勢: 287 288 1):適合多個相同的程序代碼的線程去處理同一個資源 289 290 2):可以避免java中的單繼承的限制 291 292 3):增加程序的健壯性,代碼可以被多個線程共享,代碼和數據獨立 293 294 295 296 297 298 提醒一下大家:main方法其實也是一個線程。在java中所以的線程都是同時啟動的,至於什么時候,哪個先執行,完全看誰先得到CPU的資源。 299 300 301 302 在java中,每次程序運行至少啟動2個線程。一個是main線程,一個是垃圾收集線程。因為每當使用java命令執行一個類的時候,實際上都會啟動一個JVM,每一個jVM實習在就是在操作系統中啟動了一個進程。 303 304 四、線程狀態轉換 305 306 技術分享 307 308 1、新建狀態(New):新創建了一個線程對象。 309 2、就緒狀態(Runnable):線程對象創建后,其他線程調用了該對象的start()方法。該狀態的線程位於可運行線程池中,變得可運行,等待獲取CPU的使用權。 310 3、運行狀態(Running):就緒狀態的線程獲取了CPU,執行程序代碼。 311 4、阻塞狀態(Blocked):阻塞狀態是線程因為某種原因放棄CPU使用權,暫時停止運行。直到線程進入就緒狀態,才有機會轉到運行狀態。阻塞的情況分三種: 312 (一)、等待阻塞:運行的線程執行wait()方法,JVM會把該線程放入等待池中。 313 (二)、同步阻塞:運行的線程在獲取對象的同步鎖時,若該同步鎖被別的線程占用,則JVM會把該線程放入鎖池中。 314 (三)、其他阻塞:運行的線程執行sleep()或join()方法,或者發出了I/O請求時,JVM會把該線程置為阻塞狀態。當sleep()狀態超時、join()等待線程終止或者超時、或者I/O處理完畢時,線程重新轉入就緒狀態。 315 5、死亡狀態(Dead):線程執行完了或者因異常退出了run()方法,該線程結束生命周期。 316 五、線程調度 317 318 線程的調度 319 320 1、調整線程優先級:Java線程有優先級,優先級高的線程會獲得較多的運行機會。 321 322 Java線程的優先級用整數表示,取值范圍是1~10,Thread類有以下三個靜態常量: 323 static int MAX_PRIORITY 324 線程可以具有的最高優先級,取值為10。 325 static int MIN_PRIORITY 326 線程可以具有的最低優先級,取值為1。 327 static int NORM_PRIORITY 328 分配給線程的默認優先級,取值為5。 329 330 Thread類的setPriority()和getPriority()方法分別用來設置和獲取線程的優先級。 331 332 每個線程都有默認的優先級。主線程的默認優先級為Thread.NORM_PRIORITY。 333 線程的優先級有繼承關系,比如A線程中創建了B線程,那么B將和A具有相同的優先級。 334 JVM提供了10個線程優先級,但與常見的操作系統都不能很好的映射。如果希望程序能移植到各個操作系統中,應該僅僅使用Thread類有以下三個靜態常量作為優先級,這樣能保證同樣的優先級采用了同樣的調度方式。 335 336 2、線程睡眠:Thread.sleep(long millis)方法,使線程轉到阻塞狀態。millis參數設定睡眠的時間,以毫秒為單位。當睡眠結束后,就轉為就緒(Runnable)狀態。sleep()平台移植性好。 337 338 3、線程等待:Object類中的wait()方法,導致當前的線程等待,直到其他線程調用此對象的 notify() 方法或 notifyAll() 喚醒方法。這個兩個喚醒方法也是Object類中的方法,行為等價於調用 wait(0) 一樣。 339 340 4、線程讓步:Thread.yield() 方法,暫停當前正在執行的線程對象,把執行機會讓給相同或者更高優先級的線程。 341 342 5、線程加入:join()方法,等待其他線程終止。在當前線程中調用另一個線程的join()方法,則當前線程轉入阻塞狀態,直到另一個進程運行結束,當前線程再由阻塞轉為就緒狀態。 343 344 6、線程喚醒:Object類中的notify()方法,喚醒在此對象監視器上等待的單個線程。如果所有線程都在此對象上等待,則會選擇喚醒其中一個線程。選擇是任意性的,並在對實現做出決定時發生。線程通過調用其中一個 wait 方法,在對象的監視器上等待。 直到當前的線程放棄此對象上的鎖定,才能繼續執行被喚醒的線程。被喚醒的線程將以常規方式與在該對象上主動同步的其他所有線程進行競爭;例如,喚醒的線程在作為鎖定此對象的下一個線程方面沒有可靠的特權或劣勢。類似的方法還有一個notifyAll(),喚醒在此對象監視器上等待的所有線程。 345 注意:Thread中suspend()和resume()兩個方法在JDK1.5中已經廢除,不再介紹。因為有死鎖傾向。 346 六、常用函數說明 347 348 ①sleep(long millis): 在指定的毫秒數內讓當前正在執行的線程休眠(暫停執行) 349 350 ②join():指等待t線程終止。 351 使用方式。 352 353 join是Thread類的一個方法,啟動線程后直接調用,即join()的作用是:“等待該線程終止”,這里需要理解的就是該線程是指的主線程等待子線程的終止。也就是在子線程調用了join()方法后面的代碼,只有等到子線程結束了才能執行。 354 355 Thread t = new AThread(); t.start(); t.join(); 356 為什么要用join()方法 357 358 在很多情況下,主線程生成並起動了子線程,如果子線程里要進行大量的耗時的運算,主線程往往將於子線程之前結束,但是如果主線程處理完其他的事務后,需要用到子線程的處理結果,也就是主線程需要等待子線程執行完成之后再結束,這個時候就要用到join()方法了。 359 360 不加join。 361 /** 362 *@functon 多線程學習,join 363 *@author 林炳文 364 *@time 2015.3.9 365 */ 366 package com.multithread.join; 367 class Thread1 extends Thread{ 368 private String name; 369 public Thread1(String name) { 370 super(name); 371 this.name=name; 372 } 373 public void run() { 374 System.out.println(Thread.currentThread().getName() + " 線程運行開始!"); 375 for (int i = 0; i < 5; i++) { 376 System.out.println("子線程"+name + "運行 : " + i); 377 try { 378 sleep((int) Math.random() * 10); 379 } catch (InterruptedException e) { 380 e.printStackTrace(); 381 } 382 } 383 System.out.println(Thread.currentThread().getName() + " 線程運行結束!"); 384 } 385 } 386 387 public class Main { 388 389 public static void main(String[] args) { 390 System.out.println(Thread.currentThread().getName()+"主線程運行開始!"); 391 Thread1 mTh1=new Thread1("A"); 392 Thread1 mTh2=new Thread1("B"); 393 mTh1.start(); 394 mTh2.start(); 395 System.out.println(Thread.currentThread().getName()+ "主線程運行結束!"); 396 397 } 398 399 } 400 401 402 403 輸出結果: 404 main主線程運行開始! 405 main主線程運行結束! 406 B 線程運行開始! 407 子線程B運行 : 0 408 A 線程運行開始! 409 子線程A運行 : 0 410 子線程B運行 : 1 411 子線程A運行 : 1 412 子線程A運行 : 2 413 子線程A運行 : 3 414 子線程A運行 : 4 415 A 線程運行結束! 416 子線程B運行 : 2 417 子線程B運行 : 3 418 子線程B運行 : 4 419 B 線程運行結束! 420 發現主線程比子線程早結束 421 422 加join 423 public class Main { 424 425 public static void main(String[] args) { 426 System.out.println(Thread.currentThread().getName()+"主線程運行開始!"); 427 Thread1 mTh1=new Thread1("A"); 428 Thread1 mTh2=new Thread1("B"); 429 mTh1.start(); 430 mTh2.start(); 431 try { 432 mTh1.join(); 433 } catch (InterruptedException e) { 434 e.printStackTrace(); 435 } 436 try { 437 mTh2.join(); 438 } catch (InterruptedException e) { 439 e.printStackTrace(); 440 } 441 System.out.println(Thread.currentThread().getName()+ "主線程運行結束!"); 442 443 } 444 445 } 446 447 運行結果: 448 main主線程運行開始! 449 A 線程運行開始! 450 子線程A運行 : 0 451 B 線程運行開始! 452 子線程B運行 : 0 453 子線程A運行 : 1 454 子線程B運行 : 1 455 子線程A運行 : 2 456 子線程B運行 : 2 457 子線程A運行 : 3 458 子線程B運行 : 3 459 子線程A運行 : 4 460 子線程B運行 : 4 461 A 線程運行結束! 462 主線程一定會等子線程都結束了才結束 463 464 ③yield():暫停當前正在執行的線程對象,並執行其他線程。 465 Thread.yield()方法作用是:暫停當前正在執行的線程對象,並執行其他線程。 466 yield()應該做的是讓當前運行線程回到可運行狀態,以允許具有相同優先級的其他線程獲得運行機會。因此,使用yield()的目的是讓相同優先級的線程之間能適當的輪轉執行。但是,實際中無法保證yield()達到讓步目的,因為讓步的線程還有可能被線程調度程序再次選中。 467 468 結論:yield()從未導致線程轉到等待/睡眠/阻塞狀態。在大多數情況下,yield()將導致線程從運行狀態轉到可運行狀態,但有可能沒有效果。可看上面的圖。 469 /** 470 *@functon 多線程學習 yield 471 *@author 林炳文 472 *@time 2015.3.9 473 */ 474 package com.multithread.yield; 475 class ThreadYield extends Thread{ 476 public ThreadYield(String name) { 477 super(name); 478 } 479 480 @Override 481 public void run() { 482 for (int i = 1; i <= 50; i++) { 483 System.out.println("" + this.getName() + "-----" + i); 484 // 當i為30時,該線程就會把CPU時間讓掉,讓其他或者自己的線程執行(也就是誰先搶到誰執行) 485 if (i ==30) { 486 this.yield(); 487 } 488 } 489 490 } 491 } 492 493 public class Main { 494 495 public static void main(String[] args) { 496 497 ThreadYield yt1 = new ThreadYield("張三"); 498 ThreadYield yt2 = new ThreadYield("李四"); 499 yt1.start(); 500 yt2.start(); 501 } 502 503 } 504 505 運行結果: 506 第一種情況:李四(線程)當執行到30時會CPU時間讓掉,這時張三(線程)搶到CPU時間並執行。 507 508 第二種情況:李四(線程)當執行到30時會CPU時間讓掉,這時李四(線程)搶到CPU時間並執行。 509 510 sleep()和yield()的區別 511 sleep()和yield()的區別):sleep()使當前線程進入停滯狀態,所以執行sleep()的線程在指定的時間內肯定不會被執行;yield()只是使當前線程重新回到可執行狀態,所以執行yield()的線程有可能在進入到可執行狀態后馬上又被執行。 512 sleep 方法使當前運行中的線程睡眼一段時間,進入不可運行狀態,這段時間的長短是由程序設定的,yield 方法使當前線程讓出 CPU 占有權,但讓出的時間是不可設定的。實際上,yield()方法對應了如下操作:先檢測當前是否有相同優先級的線程處於同可運行狀態,如有,則把 CPU 的占有權交給此線程,否則,繼續運行原來的線程。所以yield()方法稱為“退讓”,它把運行機會讓給了同等優先級的其他線程 513 另外,sleep 方法允許較低優先級的線程獲得運行機會,但 yield() 方法執行時,當前線程仍處在可運行狀態,所以,不可能讓出較低優先級的線程些時獲得 CPU 占有權。在一個運行系統中,如果較高優先級的線程沒有調用 sleep 方法,又沒有受到 I\O 阻塞,那么,較低優先級線程只能等待所有較高優先級的線程運行結束,才有機會運行。 514 515 ④setPriority(): 更改線程的優先級。 516 MIN_PRIORITY = 1 517 NORM_PRIORITY = 5 518 MAX_PRIORITY = 10 519 520 用法: 521 Thread4 t1 = new Thread4("t1"); 522 Thread4 t2 = new Thread4("t2"); 523 t1.setPriority(Thread.MAX_PRIORITY); 524 t2.setPriority(Thread.MIN_PRIORITY); 525 526 ⑤interrupt():中斷某個線程,這種結束方式比較粗暴,如果t線程打開了某個資源還沒來得及關閉也就是run方法還沒有執行完就強制結束線程,會導致資源無法關閉 527 要想結束進程最好的辦法就是用sleep()函數的例子程序里那樣,在線程類里面用以個boolean型變量來控制run()方法什么時候結束,run()方法一結束,該線程也就結束了。 528 529 ⑥wait() 530 531 Obj.wait(),與Obj.notify()必須要與synchronized(Obj)一起使用,也就是wait,與notify是針對已經獲取了Obj鎖進行操作,從語法角度來說就是Obj.wait(),Obj.notify必須在synchronized(Obj){...}語句塊內。從功能上來說wait就是說線程在獲取對象鎖后,主動釋放對象鎖,同時本線程休眠。直到有其它線程調用對象的notify()喚醒該線程,才能繼續獲取對象鎖,並繼續執行。相應的notify()就是對對象鎖的喚醒操作。但有一點需要注意的是notify()調用后,並不是馬上就釋放對象鎖的,而是在相應的synchronized(){}語句塊執行結束,自動釋放鎖后,JVM會在wait()對象鎖的線程中隨機選取一線程,賦予其對象鎖,喚醒線程,繼續執行。這樣就提供了在線程間同步、喚醒的操作。Thread.sleep()與Object.wait()二者都可以暫停當前線程,釋放CPU控制權,主要的區別在於Object.wait()在釋放CPU同時,釋放了對象鎖的控制。 532 533 單單在概念上理解清楚了還不夠,需要在實際的例子中進行測試才能更好的理解。對Object.wait(),Object.notify()的應用最經典的例子,應該是三線程打印ABC的問題了吧,這是一道比較經典的面試題,題目要求如下: 534 535 建立三個線程,A線程打印10次A,B線程打印10次B,C線程打印10次C,要求線程同時運行,交替打印10次ABC。這個問題用Object的wait(),notify()就可以很方便的解決。代碼如下: 536 537 /** 538 * wait用法 539 * @author DreamSea 540 * @time 2015.3.9 541 */ 542 package com.multithread.wait; 543 public class MyThreadPrinter2 implements Runnable { 544 545 private String name; 546 private Object prev; 547 private Object self; 548 549 private MyThreadPrinter2(String name, Object prev, Object self) { 550 this.name = name; 551 this.prev = prev; 552 this.self = self; 553 } 554 555 @Override 556 public void run() { 557 int count = 10; 558 while (count > 0) { 559 synchronized (prev) { 560 synchronized (self) { 561 System.out.print(name); 562 count--; 563 564 self.notify(); 565 } 566 try { 567 prev.wait(); 568 } catch (InterruptedException e) { 569 e.printStackTrace(); 570 } 571 } 572 573 } 574 } 575 576 public static void main(String[] args) throws Exception { 577 Object a = new Object(); 578 Object b = new Object(); 579 Object c = new Object(); 580 MyThreadPrinter2 pa = new MyThreadPrinter2("A", c, a); 581 MyThreadPrinter2 pb = new MyThreadPrinter2("B", a, b); 582 MyThreadPrinter2 pc = new MyThreadPrinter2("C", b, c); 583 584 585 new Thread(pa).start(); 586 Thread.sleep(100); //確保按順序A、B、C執行 587 new Thread(pb).start(); 588 Thread.sleep(100); 589 new Thread(pc).start(); 590 Thread.sleep(100); 591 } 592 } 593 594 595 輸出結果: 596 ABCABCABCABCABCABCABCABCABCABC 597 598 先來解釋一下其整體思路,從大的方向上來講,該問題為三線程間的同步喚醒操作,主要的目的就是ThreadA->ThreadB->ThreadC->ThreadA循環執行三個線程。為了控制線程執行的順序,那么就必須要確定喚醒、等待的順序,所以每一個線程必須同時持有兩個對象鎖,才能繼續執行。一個對象鎖是prev,就是前一個線程所持有的對象鎖。還有一個就是自身對象鎖。主要的思想就是,為了控制執行的順序,必須要先持有prev鎖,也就前一個線程要釋放自身對象鎖,再去申請自身對象鎖,兩者兼備時打印,之后首先調用self.notify()釋放自身對象鎖,喚醒下一個等待線程,再調用prev.wait()釋放prev對象鎖,終止當前線程,等待循環結束后再次被喚醒。運行上述代碼,可以發現三個線程循環打印ABC,共10次。程序運行的主要過程就是A線程最先運行,持有C,A對象鎖,后釋放A,C鎖,喚醒B。線程B等待A鎖,再申請B鎖,后打印B,再釋放B,A鎖,喚醒C,線程C等待B鎖,再申請C鎖,后打印C,再釋放C,B鎖,喚醒A。看起來似乎沒什么問題,但如果你仔細想一下,就會發現有問題,就是初始條件,三個線程按照A,B,C的順序來啟動,按照前面的思考,A喚醒B,B喚醒C,C再喚醒A。但是這種假設依賴於JVM中線程調度、執行的順序。 599 wait和sleep區別 600 共同點: 601 1. 他們都是在多線程的環境下,都可以在程序的調用處阻塞指定的毫秒數,並返回。 602 2. wait()和sleep()都可以通過interrupt()方法 打斷線程的暫停狀態 ,從而使線程立刻拋出InterruptedException。 603 如果線程A希望立即結束線程B,則可以對線程B對應的Thread實例調用interrupt方法。如果此刻線程B正在wait/sleep /join,則線程B會立刻拋出InterruptedException,在catch() {} 中直接return即可安全地結束線程。 604 需要注意的是,InterruptedException是線程自己從內部拋出的,並不是interrupt()方法拋出的。對某一線程調用 interrupt()時,如果該線程正在執行普通的代碼,那么該線程根本就不會拋出InterruptedException。但是,一旦該線程進入到 wait()/sleep()/join()后,就會立刻拋出InterruptedException 。 605 不同點: 606 1. Thread類的方法:sleep(),yield()等 607 Object的方法:wait()和notify()等 608 2. 每個對象都有一個鎖來控制同步訪問。Synchronized關鍵字可以和對象的鎖交互,來實現線程的同步。 609 sleep方法沒有釋放鎖,而wait方法釋放了鎖,使得其他線程可以使用同步控制塊或者方法。 610 3. wait,notify和notifyAll只能在同步控制方法或者同步控制塊里面使用,而sleep可以在任何地方使用 611 4. sleep必須捕獲異常,而wait,notify和notifyAll不需要捕獲異常 612 所以sleep()和wait()方法的最大區別是: 613 sleep()睡眠時,保持對象鎖,仍然占有該鎖; 614 而wait()睡眠時,釋放對象鎖。 615 但是wait()和sleep()都可以通過interrupt()方法打斷線程的暫停狀態,從而使線程立刻拋出InterruptedException(但不建議使用該方法)。 616 sleep()方法 617 sleep()使當前線程進入停滯狀態(阻塞當前線程),讓出CUP的使用、目的是不讓當前線程獨自霸占該進程所獲的CPU資源,以留一定時間給其他線程執行的機會; 618 sleep()是Thread類的Static(靜態)的方法;因此他不能改變對象的機鎖,所以當在一個Synchronized塊中調用Sleep()方法是,線程雖然休眠了,但是對象的機鎖並木有被釋放,其他線程無法訪問這個對象(即使睡着也持有對象鎖)。 619 在sleep()休眠時間期滿后,該線程不一定會立即執行,這是因為其它線程可能正在運行而且沒有被調度為放棄執行,除非此線程具有更高的優先級。 620 wait()方法 621 wait()方法是Object類里的方法;當一個線程執行到wait()方法時,它就進入到一個和該對象相關的等待池中,同時失去(釋放)了對象的機鎖(暫時失去機鎖,wait(long timeout)超時時間到后還需要返還對象鎖);其他線程可以訪問; 622 wait()使用notify或者notifyAlll或者指定睡眠時間來喚醒當前等待池中的線程。 623 wiat()必須放在synchronized block中,否則會在program runtime時扔出”java.lang.IllegalMonitorStateException“異常。 624 七、常見線程名詞解釋 625 626 主線程:JVM調用程序main()所產生的線程。 627 當前線程:這個是容易混淆的概念。一般指通過Thread.currentThread()來獲取的進程。 628 后台線程:指為其他線程提供服務的線程,也稱為守護線程。JVM的垃圾回收線程就是一個后台線程。用戶線程和守護線程的區別在於,是否等待主線程依賴於主線程結束而結束 629 前台線程:是指接受后台線程服務的線程,其實前台后台線程是聯系在一起,就像傀儡和幕后操縱者一樣的關系。傀儡是前台線程、幕后操縱者是后台線程。由前台線程創建的線程默認也是前台線程。可以通過isDaemon()和setDaemon()方法來判斷和設置一個線程是否為后台線程。 630 線程類的一些常用方法: 631 632 sleep(): 強迫一個線程睡眠N毫秒。 633 isAlive(): 判斷一個線程是否存活。 634 join(): 等待線程終止。 635 activeCount(): 程序中活躍的線程數。 636 enumerate(): 枚舉程序中的線程。 637 currentThread(): 得到當前線程。 638 isDaemon(): 一個線程是否為守護線程。 639 setDaemon(): 設置一個線程為守護線程。(用戶線程和守護線程的區別在於,是否等待主線程依賴於主線程結束而結束) 640 setName(): 為線程設置一個名稱。 641 wait(): 強迫一個線程等待。 642 notify(): 通知一個線程繼續運行。 643 setPriority(): 設置一個線程的優先級。 644 八、線程同步 645 646 1、synchronized關鍵字的作用域有二種: 647 1)是某個對象實例內,synchronized aMethod(){}可以防止多個線程同時訪問這個對象的synchronized方法(如果一個對象有多個synchronized方法,只要一個線程訪問了其中的一個synchronized方法,其它線程不能同時訪問這個對象中任何一個synchronized方法)。這時,不同的對象實例的synchronized方法是不相干擾的。也就是說,其它線程照樣可以同時訪問相同類的另一個對象實例中的synchronized方法; 648 2)是某個類的范圍,synchronized static aStaticMethod{}防止多個線程同時訪問這個類中的synchronized static 方法。它可以對類的所有對象實例起作用。 649 650 2、除了方法前用synchronized關鍵字,synchronized關鍵字還可以用於方法中的某個區塊中,表示只對這個區塊的資源實行互斥訪問。用法是: synchronized(this){/*區塊*/},它的作用域是當前對象; 651 652 3、synchronized關鍵字是不能繼承的,也就是說,基類的方法synchronized f(){} 在繼承類中並不自動是synchronized f(){},而是變成了f(){}。繼承類需要你顯式的指定它的某個方法為synchronized方法; 653 654 Java對多線程的支持與同步機制深受大家的喜愛,似乎看起來使用了synchronized關鍵字就可以輕松地解決多線程共享數據同步問題。到底如何?――還得對synchronized關鍵字的作用進行深入了解才可定論。 655 656 總的說來,synchronized關鍵字可以作為函數的修飾符,也可作為函數內的語句,也就是平時說的同步方法和同步語句塊。如果再細的分類,synchronized可作用於instance變量、object reference(對象引用)、static函數和class literals(類名稱字面常量)身上。 657 658 在進一步闡述之前,我們需要明確幾點: 659 660 A.無論synchronized關鍵字加在方法上還是對象上,它取得的鎖都是對象,而不是把一段代碼或函數當作鎖――而且同步方法很可能還會被其他線程的對象訪問。 661 662 B.每個對象只有一個鎖(lock)與之相關聯。 663 664 C.實現同步是要很大的系統開銷作為代價的,甚至可能造成死鎖,所以盡量避免無謂的同步控制。 665 666 接着來討論synchronized用到不同地方對代碼產生的影響: 667 668 669 670 假設P1、P2是同一個類的不同對象,這個類中定義了以下幾種情況的同步塊或同步方法,P1、P2就都可以調用它們。 671 672 673 674 1. 把synchronized當作函數修飾符時,示例代碼如下: 675 676 Public synchronized void methodAAA() 677 678 { 679 680 //…. 681 682 } 683 684 這也就是同步方法,那這時synchronized鎖定的是哪個對象呢?它鎖定的是調用這個同步方法對象。也就是說,當一個對象P1在不同的線程中執行這個同步方法時,它們之間會形成互斥,達到同步的效果。但是這個對象所屬的Class所產生的另一對象P2卻可以任意調用這個被加了synchronized關鍵字的方法。 685 686 上邊的示例代碼等同於如下代碼: 687 688 public void methodAAA() 689 690 { 691 692 synchronized (this) // (1) 693 694 { 695 696 //….. 697 698 } 699 700 } 701 702 (1)處的this指的是什么呢?它指的就是調用這個方法的對象,如P1。可見同步方法實質是將synchronized作用於object reference。――那個拿到了P1對象鎖的線程,才可以調用P1的同步方法,而對P2而言,P1這個鎖與它毫不相干,程序也可能在這種情形下擺脫同步機制的控制,造成數據混亂:( 703 704 2.同步塊,示例代碼如下: 705 706 public void method3(SomeObject so) 707 708 { 709 710 synchronized(so) 711 712 { 713 714 //….. 715 716 } 717 718 } 719 720 這時,鎖就是so這個對象,誰拿到這個鎖誰就可以運行它所控制的那段代碼。當有一個明確的對象作為鎖時,就可以這樣寫程序,但當沒有明確的對象作為鎖,只是想讓一段代碼同步時,可以創建一個特殊的instance變量(它得是一個對象)來充當鎖: 721 722 class Foo implements Runnable 723 724 { 725 726 private byte[] lock = new byte[0]; // 特殊的instance變量 727 728 Public void methodA() 729 730 { 731 732 synchronized(lock) { //… } 733 734 } 735 736 //….. 737 738 } 739 740 注:零長度的byte數組對象創建起來將比任何對象都經濟――查看編譯后的字節碼:生成零長度的byte[]對象只需3條操作碼,而Object lock = new Object()則需要7行操作碼。 741 742 3.將synchronized作用於static 函數,示例代碼如下: 743 744 Class Foo 745 746 { 747 748 public synchronized static void methodAAA() // 同步的static 函數 749 750 { 751 752 //…. 753 754 } 755 756 public void methodBBB() 757 758 { 759 760 synchronized(Foo.class) // class literal(類名稱字面常量) 761 762 } 763 764 } 765 766 代碼中的methodBBB()方法是把class literal作為鎖的情況,它和同步的static函數產生的效果是一樣的,取得的鎖很特別,是當前調用這個方法的對象所屬的類(Class,而不再是由這個Class產生的某個具體對象了)。 767 768 記得在《Effective Java》一書中看到過將 Foo.class和 P1.getClass()用於作同步鎖還不一樣,不能用P1.getClass()來達到鎖這個Class的目的。P1指的是由Foo類產生的對象。 769 770 可以推斷:如果一個類中定義了一個synchronized的static函數A,也定義了一個synchronized 的instance函數B,那么這個類的同一對象Obj在多線程中分別訪問A和B兩個方法時,不會構成同步,因為它們的鎖都不一樣。A方法的鎖是Obj這個對象,而B的鎖是Obj所屬的那個Class。 771 772 773 774 1、線程同步的目的是為了保護多個線程反問一個資源時對資源的破壞。 775 776 2、線程同步方法是通過鎖來實現,每個對象都有切僅有一個鎖,這個鎖與一個特定的對象關聯,線程一旦獲取了對象鎖,其他訪問該對象的線程就無法再訪問該對象的其他非同步方法。 777 778 3、對於靜態同步方法,鎖是針對這個類的,鎖對象是該類的Class對象。靜態和非靜態方法的鎖互不干預。一個線程獲得鎖,當在一個同步方法中訪問另外對象上的同步方法時,會獲取這兩個對象鎖。 779 780 4、對於同步,要時刻清醒在哪個對象上同步,這是關鍵。 781 782 5、編寫線程安全的類,需要時刻注意對多個線程競爭訪問資源的邏輯和安全做出正確的判斷,對“原子”操作做出分析,並保證原子操作期間別的線程無法訪問競爭資源。 783 784 6、當多個線程等待一個對象鎖時,沒有獲取到鎖的線程將發生阻塞。 785 786 7、死鎖是線程間相互等待鎖鎖造成的,在實際中發生的概率非常的小。真讓你寫個死鎖程序,不一定好使,呵呵。但是,一旦程序發生死鎖,程序將死掉。 787 788 789 九、線程數據傳遞 790 791 在傳統的同步開發模式下,當我們調用一個函數時,通過這個函數的參數將數據傳入,並通過這個函數的返回值來返回最終的計算結果。但在多線程的異步開發模式下,數據的傳遞和返回和同步開發模式有很大的區別。由於線程的運行和結束是不可預料的,因此,在傳遞和返回數據時就無法象函數一樣通過函數參數和return語句來返回數據。 792 793 9.1、通過構造方法傳遞數據 794 在創建線程時,必須要建立一個Thread類的或其子類的實例。因此,我們不難想到在調用start方法之前通過線程類的構造方法將數據傳入線程。並將傳入的數據使用類變量保存起來,以便線程使用(其實就是在run方法中使用)。下面的代碼演示了如何通過構造方法來傳遞數據: 795 796 797 package mythread; 798 public class MyThread1 extends Thread 799 { 800 private String name; 801 public MyThread1(String name) 802 { 803 this.name = name; 804 } 805 public void run() 806 { 807 System.out.println("hello " + name); 808 } 809 public static void main(String[] args) 810 { 811 Thread thread = new MyThread1("world"); 812 thread.start(); 813 } 814 } 815 由於這種方法是在創建線程對象的同時傳遞數據的,因此,在線程運行之前這些數據就就已經到位了,這樣就不會造成數據在線程運行后才傳入的現象。如果要傳遞更復雜的數據,可以使用集合、類等數據結構。使用構造方法來傳遞數據雖然比較安全,但如果要傳遞的數據比較多時,就會造成很多不便。由於Java沒有默認參數,要想實現類似默認參數的效果,就得使用重載,這樣不但使構造方法本身過於復雜,又會使構造方法在數量上大增。因此,要想避免這種情況,就得通過類方法或類變量來傳遞數據。 816 9.2、通過變量和方法傳遞數據 817 向對象中傳入數據一般有兩次機會,第一次機會是在建立對象時通過構造方法將數據傳入,另外一次機會就是在類中定義一系列的public的方法或變量(也可稱之為字段)。然后在建立完對象后,通過對象實例逐個賦值。下面的代碼是對MyThread1類的改版,使用了一個setName方法來設置 name變量: 818 819 820 821 package mythread; 822 public class MyThread2 implements Runnable 823 { 824 private String name; 825 public void setName(String name) 826 { 827 this.name = name; 828 } 829 public void run() 830 { 831 System.out.println("hello " + name); 832 } 833 public static void main(String[] args) 834 { 835 MyThread2 myThread = new MyThread2(); 836 myThread.setName("world"); 837 Thread thread = new Thread(myThread); 838 thread.start(); 839 } 840 } 841 9.3、通過回調函數傳遞數據 842 上面討論的兩種向線程中傳遞數據的方法是最常用的。但這兩種方法都是main方法中主動將數據傳入線程類的。這對於線程來說,是被動接收這些數據的。然而,在有些應用中需要在線程運行的過程中動態地獲取數據,如在下面代碼的run方法中產生了3個隨機數,然后通過Work類的process方法求這三個隨機數的和,並通過Data類的value將結果返回。從這個例子可以看出,在返回value之前,必須要得到三個隨機數。也就是說,這個 value是無法事先就傳入線程類的。 843 844 845 846 package mythread; 847 class Data 848 { 849 public int value = 0; 850 } 851 class Work 852 { 853 public void process(Data data, Integer numbers) 854 { 855 for (int n : numbers) 856 { 857 data.value += n; 858 } 859 } 860 } 861 public class MyThread3 extends Thread 862 { 863 private Work work; 864 public MyThread3(Work work) 865 { 866 this.work = work; 867 } 868 public void run() 869 { 870 java.util.Random random = new java.util.Random(); 871 Data data = new Data(); 872 int n1 = random.nextInt(1000); 873 int n2 = random.nextInt(2000); 874 int n3 = random.nextInt(3000); 875 work.process(data, n1, n2, n3); // 使用回調函數 876 System.out.println(String.valueOf(n1) + "+" + String.valueOf(n2) + "+" 877 + String.valueOf(n3) + "=" + data.value); 878 } 879 public static void main(String[] args) 880 { 881 Thread thread = new MyThread3(new Work()); 882 thread.start(); 883 } 884 }