java.util.concurrent

0熱

2答えて

LinkedBlockingQueue - プロデューサ/コンシューマ

私はLinkedBlockingQueue周りに管理簡単な生産者 - 消費者のシナリオで2つのスレッドを持っています。私はtake()を使用する消費者のスレッドで つまり私は、要素がキューに入ってくる一方で、消費者をブロックしたいです。 プロデューサスレッドでoffer()を使用してキューに追加してもいいですか？put()ではありませんか？それは何か問題を引き起こすだろうか？私が意味する は、ta

java multithreading concurrency java.util.concurrent 2016-04-22

---

1熱

1答えて

原子配列を効率的に成長させる

Atomic(Double|Integer|Long|Reference)Arrayをクリーンで効率的に成長させる方法はありますか？私の特別なケースでは、コピー中の同時書き込みはありません。新しいものを作成して、ループ内の宛先アレイにソース配列をコピーするための1つの明らかな方法：このコードを Atomic*Array dest = new Atomic*Array(newSize); for

java performance concurrency java.util.concurrent 2016-04-27

---

2熱

1答えて

LockSupport.park（オブジェクトブロッカー）のパラメータの使い方は？

LockSupport.park（Object blocker）を呼び出して、現在のスレッドをパークすることができます。しかし、パラメータ "blocker"の使い方は何ですか？ドキュメントから

java java.util.concurrent 2016-04-29

---

-2熱

1答えて

なぜCountDownLatchソースが複雑なのですか？

utils.concurrentにこのような複雑なソースコードがある理由を知りたい。 これは私がCountDownLatchのために出したコードですが、テストしたところ、ソースコードで何か似たものが見つかると思っていましたが、それはスーパーコンプレックスです。 私の実装に間違いはありますか？ public class CountDown { private int count;

java multithreading concurrency java.util.concurrent 2016-05-01

---

2熱

2答えて

なぜfuture isDone（）がFuture get（）のようなプログラムをブロックするのか？

私は各要素が一つのフレームを生成するための情報やリソースを持っているList<Callable<Long>> tasksを生成し、メインスレッドを持っている...問題はアニメーションであり、フラクタルフラクタルアニメーションを生成するための を、プログラムを書いています。私はExecutorServiceを使って作品を投稿します。 ユーザが微積分を停止したい場合、これらのセカンダリスレッドをキャン

java multithreading javafx-8 java.util.concurrent 2016-03-18

---

-2熱

2答えて

なぜ私のcyclicBarrierがヌルですか？

私はciclycbarrierと小さなアプリを作成しようとしています。私は私のCyclicBarrierを作成し、コンストラクタで public FileDownloader(String line, int maxDownload){ this.position = 0; this.line = line; this.maxDownload = maxDownloa

java multithreading concurrency java.util.concurrent cyclicbarrier 2016-05-09

---

0熱

1答えて

Javaの同時実行性を使用して複数のサーバーインスタンスとクライアントインスタンスを実行するシミュレーション

1台のマシン上で複数のサーバーとクライアントを実行するシミュレーションを行います。 私は、Javaの並行性パッケージを使用して複数のサーバーとクライアントのスレッドを作成する予定です。 サーバーとクライアントを区別し、ポート番号だけを使用して区別します。 私はサーバー用の一連の800XXポートとクライアント用の900XXポートを用意します。 私がしていることが正しいかどうかを知る必要があります。そ

java multithreading sockets client-server java.util.concurrent 2016-03-23

---

4熱

1答えて

LongAdderを使用して統計カウンタの最大値を計算する？

AtomicLongsを使用して統計情報を収集しています。一部のユーザーがこれらの競合を見ていて、代わりにLongAdderを使用するように提案しています。しかし、私たちは現在、アトミックで行っているように、最大​​値を計算する方法を参照してくださいません： AtomicLong _current, _total, _max; ... void add(long delta) {

java concurrency statistics java-8 java.util.concurrent 2016-04-01

---

5熱

1答えて

将来のタスクはThreadPoolExecutorから拒否されました

私はThreadPoolExecutorを持っており、タスクを提出しています。 private ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<Runnable>(1)); このコードはThreadPool

java java.util.concurrent 2016-02-11

---

11熱

9答えて

完成した作業項目の順序が保存されるマルチスレッド実行

私は作業単位の流れを持っています。これは順次処理される "作業項目"と呼ばれます。私はマルチスレッドの仕事をして処理をスピードアップしたいと思います。 制約：これらの作業項目は処理中に特定の順序になりますが、順序は関係ありませんが、処理が終了するとその順序を復元する必要があります。 このような何か： |.| |.| |4| |3| |2| <- incomi

java multithreading performance concurrency java.util.concurrent 2016-04-05

---