Java Blocking Queue问题 - 未名空间MITBBS历史存档

国际科技财经博客移民网络热点娱乐民生时事公众号

Redian新闻

>未名空间

>JobHunting - 待字闺中

Java Blocking Queue问题

Java Blocking Queue问题# JobHunting - 待字闺中

p*82015-04-09 07:04

1 楼

网上看到的实现：http://tutorials.jenkov.com/java-concurrency/blocking-queues.html
如果用一个锁，那么同时只能有一个线程调用其中的一个方法，比如说线程1调用put()
, 发现queue满了，就等在那；其他线程肯定不能调用任意一个方法，线程1因为block
也不会去调用take(),那不是永远锁着了？

g*g2015-04-09 07:04

2 楼

You don't need another lock.

()
block

【在 p*******8 的大作中提到】

: 网上看到的实现：http://tutorials.jenkov.com/java-concurrency/blocking-queues.html
: 如果用一个锁，那么同时只能有一个线程调用其中的一个方法，比如说线程1调用put()
: , 发现queue满了，就等在那；其他线程肯定不能调用任意一个方法，线程1因为block
: 也不会去调用take(),那不是永远锁着了？

b*n2015-04-09 07:04

3 楼

说过多少遍了， just Google grepcode blocking queque, 就知道Java怎么实现
blockingqueue

()
block

【在 p*******8 的大作中提到】

p*82015-04-09 07:04

4 楼

好虫大神能展开说说吗？synchronized就算一个lock了吧？

【在 g*****g 的大作中提到】

: You don't need another lock.
:
: ()
: block

p*82015-04-09 07:04

5 楼

看了啊，ArrayBlockingQueue的思路跟上面链接的一样，LinkedBlockingQueue用了两
个单独的takeLock, putLock, 怎样保证thread-safe?
LinkedBlockingQueue: http://www.docjar.com/html/api/java/util/concurrent/LinkedBlockingQueue.java.html
ArrayBlockingQueue:
http://grepcode.com/file/repository.grepcode.com/java/root/jdk/

【在 b******n 的大作中提到】

: 说过多少遍了， just Google grepcode blocking queque, 就知道Java怎么实现
: blockingqueue
:
: ()
: block

H*n2015-04-09 07:04

6 楼

对于同一个queue对象，同时只能有一个synchronized的method被调用，所以用
synchronized就完全可以做到了。

()
block

【在 p*******8 的大作中提到】

p*82015-04-09 07:04

7 楼

我明白你的意思，我找到我前面问题的答案了：
1. 调用wait() 会release掉当前的锁, 所以其他线程可以调用take()
2. 关于java linkedBlockingQueue的实现，为什么两个不用的锁也可以, 因为enqueue
/dequeue的操作只分别对head/tail的操作，所以put/take可以同时进行

【在 H********n 的大作中提到】

: 对于同一个queue对象，同时只能有一个synchronized的method被调用，所以用
: synchronized就完全可以做到了。
:
: ()
: block