java.util.concurrent

1熱

2答えて

ThreadPoolExecutorはアイドルスレッドをどのように中断しますか？

ソースコードThreadPoolExecutorを調べたところ、keepAliveTimeとallowCoreThreadTimeOutの設定値がtrueになると、すべてのアイドルワーカーが中断されることがわかりました。 それが唯一のinterruptメソッドを呼び出すことができます私には少し奇妙だときrunState> = SHUTDOWN： 次のコードは、メソッドThreadPoolExecu

java java.util.concurrent 2012-04-30

---

15熱

4答えて

CountDownLatchを「キャンセル」するにはどうすればよいですか？

await()を使用して、サイズ1のCountDownLatchで待機している複数のコンシューマスレッドがあります。私は成功したときにcountDown()を呼び出す単一のプロデューサスレッドを持っています。 エラーがない場合に効果的です。 しかし、プロデューサがエラーを検出した場合、そのエラーをコンシューマスレッドに通知できるようにしたいと思います。理想的には、プロデューサにabortCount

java concurrency java.util.concurrent 2012-05-04

---

36熱

1答えて

@GuardedBy、@ThreadSafe、@ NotThreadSafe

上記の注釈は本のJCIPで広く使用されています。適切な文書がない場合でも、同期方針に関するいくつかのことが書かれているので、本当に便利だと思います。また、Intellij Ideaはこれらのアノテーションを利用していることがわかりました。実際にJava言語自体の一部になっていますか？

java concurrency java.util.concurrent 2012-07-06

---

9熱

2答えて

Semaphore.acquire（）は偽のウェイクアップのためにInterruptedExceptionをスローできますか？

一見簡単な問題：java.util.concurrent.Semaphoreがあり、acquire()を使用して許可証を取得したいと考えています。 acquire()メソッドは、スレッドが中断された場合InterruptedExceptionをスローするように指定されている： 現在のスレッド場合： は、このメソッドへのエントリ上で設定された割り込みステータスを持っています。または許可を待っている間

java semaphore java.util.concurrent 2012-08-28

---

6熱

3答えて

BufferedReader.readLine（）をFuture.cancel（true）で中断できますか？

はのは、私がスレッドを開始し、私はこのような何かを持っているとしましょう： ...//initiate all the socket connection future = executor.submit ( new Runnable() { public void run() { ... ... while ((str = in.readL

java multithreading java.util.concurrent 2012-04-02

---

1熱

1答えて

Playframework InvocationTargetExceptionが発生しました：null

私はチャットの例を拡張し、5秒ごとに「滞在中」メッセージを追加しました。ブレークポイントからコードをデバッグして実行すると、完全に実行されます。しかし、私はちょうどそれは、以下のログでクラッシュアプ​​リ実行した場合：ここで // Loop while the socket is open while (inbound.isOpen()) { // Wait for a

playframework java.util.concurrent invocationtargetexception 2012-04-04

---

2熱

2答えて

動的なJavaのパーティ数の障壁

私はjavaの動的なパーティ数の障壁が必要です。私はPhaserに出くわしましたが、この解決策は私が残念なことに使用できないJava 7用です。 Java 6の解決策はありますか？さまざまなウェイターとの障壁の必要性をどのように満たす必要がありますか？

java java.util.concurrent barrier 2012-04-06

---

2熱

1答えて

java.util.concurrentクラスを使用すると、読み書きを整理できますか？

アクセス権を同期したいリソースがあるとします。これらのアクセスのほとんどは読み取り専用です。私はシステムが扱うことができるように一度に多くの読み取り専用アクセスを許可したいと思います。しかし、私は読書を止め、書いて、読書をもう一度できるようにしたいと思います。 だから、読み取りスレッドが任意の数のスレッドが同時にこれを行うことができます。この Resource r = null; readLoc

java java.util.concurrent 2012-04-10

---

2熱

1答えて

OpenJDKのLinkedBlockingQueueの実装：NodeクラスとGC

OpenJDKのLinkedBlockingQueue（java.util.concurrent内）の実装で、Nodeクラスの構造が少し混乱しています。私は以下のノードクラスの記述を再現しました ： static class Node<E> { E item; /** * One of: * - the real successor Node *

java concurrency garbage-collection queue java.util.concurrent 2012-04-11

---

2熱

3答えて

作成のScheduledThreadPoolExecutor使用エグゼキュー

私は、次のキャストが動作しない理由として、非常に混乱しています： ScheduledThreadPoolExecutor timeoutControl = (ScheduledThreadPoolExecutor) Executors.newSingleThreadScheduledExecutor(); のScheduledThreadPoolExecutorはScheduledExecut

java java.util.concurrent 2012-04-17

---