亚洲国产成人久久精品影视 ,香蕉视频亚洲一级,亚洲国产精品精华液

多線程復習

public class MyStack {
2

private int[] a;
3

private int count = 0;
4

public final int MAX_SIZE;
5

public MyStack(int size) {
7

MAX_SIZE = size;
8

a = new int[size];
9

count = 0;
10

}
11

public synchronized void push() {
13

while(count==MAX_SIZE){//這里用while而不是if因為當被喚醒時，該線程處于鎖池等待獲取鎖，這個時候可能會有別的該線改變數組的大小。所以喚醒時繼續檢查數組是否已滿。
14

try {
15

this.wait(); //釋放掉當前的對象鎖，在等待池等待
16

} catch (InterruptedException e) {
17

e.printStackTrace();
18

}
19

}
20

a[count++]=count;
21

System.out.println(Thread.currentThread().getName()+"壓入數據:"+count);
22

this.notify(); //喚醒生產者消費者線程
23

}
24

public synchronized int pop() {
26

while(count ==0){
27

try {
28

this.wait();
29

} catch (InterruptedException e) {
30

e.printStackTrace();
31

}
32

}
33

this.notify();
34

System.out.println(Thread.currentThread().getName()+"彈出數據:"+count);
35

return a[--count];
36

}
37

}
38

/**
39

*生產者
40

**/
41

public class Producer extends Thread {
42

private MyStack stack;
44

public Producer(MyStack stack){
46

this.stack = stack;
47

}
48

@Override
49

public void run() {
50

while (true) {
51

stack.push();
52

try {
53

Thread.sleep(200);
54

} catch (InterruptedException e) {
55

e.printStackTrace();
56

}
57

}
58

}
59

}
60

/**
61

*消費者
62

**/
63

public class Consumer extends Thread{
64

private MyStack stack;
66

public Consumer(MyStack stack){
68

this.stack = stack;
69

}
70

@Override
72

public void run() {
73

while(true){
74

stack.pop();
75

try {
76

Thread.sleep(300);
77

} catch (InterruptedException e) {
78

e.printStackTrace();
79

}
80

}
81

}
82

}

線程狀態圖

posted on 2010-08-19 10:19 朔望魔刃閱讀(240) 評論(0) 編輯收藏所屬分類: java

常用鏈接

留言簿

隨筆分類

隨筆檔案

文章分類

文章檔案

收藏夾

娛樂博客

牛博

搜索

最新評論

閱讀排行榜

評論排行榜


只有注冊用戶登錄后才能發表評論。




網站導航: 博客園 IT新聞 Chat2DB C++博客博問管理
相關文章: Jdk和cglib動態代理 mybatis減少resultMap列映射 restful安全認證 spring-boot配置quartz spring data jpa 小結 spring-boot data jpa 性能優化 spring-boot data jpa 復雜查詢 spring-boot-data-jpa nativeQuery 詳解 spring-boot data jpa spring-boot 分頁小問題