日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

RELATEED CONSULTING
相關(guān)咨詢(xún)
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時(shí)間：8:30-17:00
你可能遇到了下面的問(wèn)題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營(yíng)銷(xiāo)解決方案
Java多線程語(yǔ)句具體分類(lèi)的詳細(xì)介紹

在Java多線程語(yǔ)句中有很多的小的語(yǔ)句需要我們特殊的注意。wait(),notify(),notifyAll()不屬于Thread類(lèi),下面我們就來(lái)詳細(xì)的看看如何使用這幾個(gè)分類(lèi)代碼。希望大家有所收獲。

而是屬于Object基礎(chǔ)類(lèi),也就是說(shuō)每個(gè)對(duì)像都有wait(),notify(),notifyAll()的功能.因?yàn)槎紓€(gè)對(duì)像都有鎖,鎖是每個(gè)對(duì)像的基礎(chǔ),當(dāng)然操作鎖的方法也是最基礎(chǔ)了.先看java doc怎么說(shuō):

Java多線程語(yǔ)句中，wait導(dǎo)致當(dāng)前的線程等待，直到其他線程調(diào)用此對(duì)象的 notify() 方法或 notifyAll() 方法。當(dāng)前的線程必須擁有此對(duì)象監(jiān)視器。該線程發(fā)布對(duì)此監(jiān)視器的所有權(quán)并等待，直到其他線程通過(guò)調(diào)用 notify 方法，或 notifyAll 方法通知在此對(duì)象的監(jiān)視器上等待的線程醒來(lái)。然后該線程將等到重新獲得對(duì)監(jiān)視器的所有權(quán)后才能繼續(xù)執(zhí)行.

notify喚醒在此對(duì)象監(jiān)視器上等待的單個(gè)線程。如果所有線程都在此對(duì)象上等待，則會(huì)選擇喚醒其中一個(gè)線程。直到當(dāng)前的線程放棄此對(duì)象上的鎖定，才能繼續(xù)執(zhí)行被喚醒的線程。此方法只應(yīng)由作為此對(duì)象監(jiān)視器的所有者的線程來(lái)調(diào)用.

"當(dāng)前的線程必須擁有此對(duì)象監(jiān)視器"與"此方法只應(yīng)由作為此對(duì)象監(jiān)視器的所有者的線程來(lái)調(diào)用"說(shuō)明wait方法與notify方法必須在同步塊內(nèi)執(zhí)行,即synchronized(obj之內(nèi)).

調(diào)用對(duì)像wait方法后,當(dāng)前線程釋放對(duì)像鎖,進(jìn)入等待狀態(tài).直到其他線程(也只能是其他線程)通過(guò)notify 方法，或 notifyAll.該線程重新獲得對(duì)像鎖。繼續(xù)執(zhí)行,記得線程必須重新獲得對(duì)像鎖才能繼續(xù)執(zhí)行.因?yàn)閟ynchronized代碼塊內(nèi)沒(méi)有鎖是寸步不能走的.看一個(gè)很經(jīng)典的例子:

 
 
 
    
  
  
  
  1. Code  
    2.   
  
  
  2. package ProductAndConsume;  
    3.   
  
  
  3. import java.util.List;  
    4.   
  
  
  4. public class Consume implements Runnable{  
    5.   
  
  
  5. private List container = null;  
    6.   
  
  
  6. private int count;  
    7.   
  
  
  7. public Consume(List lst){  
    8.   
  
  
  8. this.container = lst;  
    9.   
  
  
  9. }  
    10.   
  
  
  10. public void run() {  
    11.   
  
  
  11. while(true){  
    12.   
  
  
  12. synchronized (container) {  
    13.   
  
  
  13. if(container.size()== 0){  
    14.   
  
  
  14. try {  
    15.   
  
  
  15. container.wait();//放棄鎖  
    16.   
  
  
  16. } catch (InterruptedException e) {  
    17.   
  
  
  17. e.printStackTrace();  
    18.   
  
  
  18. }  
    19.   
  
  
  19. }  
    20.   
  
  
  20. try {  
    21.   
  
  
  21. Thread.sleep(100);  
    22.   
  
  
  22. } catch (InterruptedException e) {  
    23.   
  
  
  23. // TODO Auto-generated catch block  
    24.   
  
  
  24. e.printStackTrace();  
    25.   
  
  
  25. }  
    26.   
  
  
  26. container.remove(0);  
    27.   
  
  
  27. container.notify();  
    28.   
  
  
  28. System.out.println("我吃了"+(++count)+"個(gè)");  
    29.   
  
  
  29. }  
    30.   
  
  
  30. }  
    31.   
  
  
  31. }  
    32.   
  
  
  32. }  
    33.   
  
  
  33. package ProductAndConsume;  
    34.   
  
  
  34. import java.util.List;  
    35.   
  
  
  35. public class Product implements Runnable {  
    36.   
  
  
  36. private List container = null;  
    37.   
  
  
  37. private int count;  
    38.   
  
  
  38. public Product(List lst) {  
    39.   
  
  
  39. this.container = lst;  
    40.   
  
  
  40. }  
    41.   
  
  
  41. public void run() {  
    42.   
  
  
  42. while (true) {  
    43.   
  
  
  43. synchronized (container) {  
    44.   
  
  
  44. if (container.size() > MultiThread.MAX) {  
    45.   
  
  
  45. try {  
    46.   
  
  
  46. container.wait();  
    47.   
  
  
  47. } catch (InterruptedException e) {  
    48.   
  
  
  48. e.printStackTrace();  
    49.   
  
  
  49. }  
    50.   
  
  
  50. }  
    51.   
  
  
  51. try {  
    52.   
  
  
  52. Thread.sleep(100);  
    53.   
  
  
  53. } catch (InterruptedException e) {  
    54.   
  
  
  54. e.printStackTrace();  
    55.   
  
  
  55. }  
    56.   
  
  
  56. container.add(new Object());  
    57.   
  
  
  57. container.notify();  
    58.   
  
  
  58. System.out.println("我生產(chǎn)了"+(++count)+"個(gè)");  
    59.   
  
  
  59. }  
    60.   
  
  
  60. }  
    61.   
  
  
  61. }  
    62.   
  
  
  62. }  
    63.   
  
  
  63. package ProductAndConsume;  
    64.   
  
  
  64. imort java.util.ArrayList;  
    65.   
  
  
  65. import java.util.List;  
    66.   
  
  
  66. public class MultiThread {  
    67.   
  
  
  67. private List container = new ArrayList();  
    68.   
  
  
  68. public final static int MAX = 5;  
    69.   
  
  
  69. public static void main(String args[]){  
    70.   
  
  
  70. MultiThread m = new MultiThread();  
    71.   
  
  
  71. new Thread(new Consume(m.getContainer())).start();  
    72.   
  
  
  72. new Thread(new Product(m.getContainer())).start();  
    73.   
  
  
  73. new Thread(new Consume(m.getContainer())).start();  
    74.   
  
  
  74. new Thread(new Product(m.getContainer())).start();  
    75.   
  
  
  75. }  
    76.   
  
  
  76. public List getContainer() {  
    77.   
  
  
  77. return container;  
    78.   
  
  
  78. }  
    79.   
  
  
  79. public void setContainer(List container) {  
    80.   
  
  
  80. this.container = container;  
    81.   
  
  
  81. } 
    82.

以上就是對(duì)Java多線程語(yǔ)句的詳細(xì)介紹。


分享名稱(chēng)：Java多線程語(yǔ)句具體分類(lèi)的詳細(xì)介紹
分享路徑：http://www.dlmjj.cn/article/djjdpgj.html