国产成人97精品免费看片,岛国大片在线观看,欧美视频一区二区三区四区

一種實(shí)現(xiàn)生產(chǎn)者－消費(fèi)者問題的新方法

生產(chǎn)者－消費(fèi)者問題，是操作系統(tǒng)的進(jìn)程管理中很重要的問題。以前的我都是用wait(),notify()方法來實(shí)現(xiàn)的。今天我在翻閱JDK1.5API幫助文檔的時(shí)候，偶然間發(fā)現(xiàn)了一個(gè)類ArrayBlockingQueue，它其中提供了以下兩個(gè)方法：

void put (E o)
Adds the specified element to the tail of this queue, waiting if necessary for space to become available.

`E`	`take()` Retrieves and removes the head of this queue, waiting if no elements are present on this queue.

我靈機(jī)一動(dòng)，用這兩個(gè)JDK中定義好的方法是不是也可以實(shí)現(xiàn)生產(chǎn)者－消費(fèi)者問題呢？試了一下，嘿，還真靈。

/*

*@author 我為J狂建立日期 2007-3-25

*

*/

package net.blogjava.lzqdiy;

import java.util.concurrent.ArrayBlockingQueue;

public class TestUtil

{

private ArrayBlockingQueue<String> queue ;

/**

* @param args

*/

public TestUtil(int capacity)

{

queue = new ArrayBlockingQueue<String>(capacity);

}

class Consumer extends Thread

{

@Override

public void run()

{

// TODO Auto-generated method stub

while (true)

{

synchronized (queue)

{

try

{

System.out.println("take:" + queue.take());

Thread.sleep(5);

} catch (InterruptedException e)

{

// TODO Auto-generated catch block

e.printStackTrace();

}

class Producer extends Thread

{

private int i;

@Override

public void run()

{

// TODO Auto-generated method stub

while (true)

{

synchronized (queue)

{

try

{

queue.put((++i) + "");

System.out.println("put:" + i);

Thread.sleep(1);

} catch (InterruptedException e)

{

// TODO Auto-generated catch block

e.printStackTrace();

}

public static void main(String[] args)

{

TestUtil t = new TestUtil(10);//阻塞隊(duì)列的容量為10

TestUtil.Producer p = t.new Producer();

p.start();

TestUtil.Consumer c = t.new Consumer();

c.start();

}

這個(gè)算法有點(diǎn)小BUG，就是當(dāng)隊(duì)列容量過小時(shí)，有可能發(fā)生死鎖。希望大家留言，來改進(jìn)這個(gè)算法。

posted on 2007-03-25 14:17 我為J狂閱讀(2055) 評(píng)論(3) 編輯收藏所屬分類: 線程

評(píng)論

# re: 一種實(shí)現(xiàn)生產(chǎn)者－消費(fèi)者問題的新方法。 2007-03-25 15:05 dennis

jdk5引入的concurrent包，了解太少，這方面的學(xué)習(xí)資料也少回復(fù) 更多評(píng)論

# re: 一種實(shí)現(xiàn)生產(chǎn)者－消費(fèi)者問題的新方法 2007-05-08 22:04 www.bushiba.com

不懂哦，只知道老師要寫偶寫出來回復(fù) 更多評(píng)論

# re: 一種實(shí)現(xiàn)生產(chǎn)者－消費(fèi)者問題的新方法 2008-08-07 11:07 pei

用了BlockingQueue還要synchronized嗎？回復(fù) 更多評(píng)論

新用戶注冊刷新評(píng)論列表


只有注冊用戶登錄后才能發(fā)表評(píng)論。




網(wǎng)站導(dǎo)航: 博客園 IT新聞 Chat2DB C++博客博問管理

<

2007年3月

>

日

一

二

三

四

五

六

25

26

27

28

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

1

2

3

4

5

6

7

導(dǎo)航

統(tǒng)計(jì)

隨筆 - 47
文章 - 30
評(píng)論 - 327
引用 - 0

常用鏈接

留言簿(11)

隨筆分類(48)

文章分類(29)