blockingqueue

1熱

4答えて

Aは、この質問のタイトルは、この存在している場合、私は疑問になり

をブロックし、まだありませんBlockingQueueの有界：、サイズによって制限され、私はJavaのBlockingQueueのが実装されているかどうかに興味がある を、ブロックされることはありませんが、あまりにも多くの要素をエンキューしようとすると例外がスローされます。 編集 - 私はBlockingQueueをExecutorに渡していますが、これはoffer（）メソッドではなくadd（）メ

java blockingqueue 2009-08-05

---

27熱

6答えて

java BlockingQueueにブロッキング・ピークがありませんか？

私はオブジェクトのブロッキングキューを持っています。 キューにオブジェクトがあるまでブロックするスレッドを作成したいと思います。 BlockingQueue.take（）によって提供される機能に似ています。 しかし、オブジェクトを正常に処理できるかどうかわからないので、私はちょうどpeek（）してオブジェクトを削除しないでください。私はそれを正常に処理できる場合にのみオブジェクトを削除したいと思い

java queue peek blockingqueue 2009-11-18

---

1熱

2答えて

JavaのBlockingQueueに同時コールを呼び出す

C++のstlキューに同時に追加すると問題が発生する可能性があります。これを解決する方法は、すべての追加/削除呼び出しにmutexロックを追加することです。 私は現時点ではJavaでプログラミングしていますが、私はBlockingQueueを使用しています。このドキュメントでは、BlockingQueueオブジェクトのput/takeを呼び出すスレッドは、取り込む余地があるまで暗黙的にブロックされ

java concurrency blockingqueue 2011-07-25

---

1熱

1答えて

ブロッキングキューインプリメンテーションでJava Notifyを正しく使用する方法

Javaマルチスレッド構成を理解しようとしていますが、ブロッキングキューの簡単な実装を記述しようとしています。 class BlockingBoundedQueue<E> { @SuppressWarnings("unchecked") BlockingBoundedQueue(int size) { fSize = size;

java multithreading thread-safety blockingqueue 2011-06-27

---

12熱

4答えて

可変遅延付きScheduledExecutorService

java.util.concurrent.BlockingQueueから要素を引き出して処理するタスクがあるとします。 public void scheduleTask(int delay, TimeUnit timeUnit) { scheduledExecutorService.scheduleWithFixedDelay(new Task(queue), 0, delay, ti

java concurrency executorservice blockingqueue 2009-10-05

---