concurrency

1熱

1答えて

私のアプリケーションでは、マルチセンサーリストバンドへのBLE接続を保持するServiceが実行されています。 Serviceは、新しいデータで毎秒何回か呼び出されるリストバンドSDKのコールバックメソッドを実装しています。異なるセンサから、タイムスタンプに対して同じObservationオブジェクト内にこれらのデータを入れたいと思います。 Observationオブジェクトはすべて60秒ごとに

0熱

1答えて

Javaのスレッド可視性問題の根本原因は何ですか？

私はthis questionに受け入れられた答えにコードを実行しようとしたが、私のマシンで無期限に実行されます。この現象を引き起こすボンネットの下で何が起こっていますか？つまり、一方のスレッドは、他方のスレッドがそうでないと見なしていますか？人々はメインメモリにフラッシュされないが、このキャッシュはどこにあるのですか？それはJVMに置かれていますか、それはCPUメモリキャッシュですか、それともC

0熱

1答えて

スプリングバッチマルチスレッドプロセッサ

複数のプロセッサクラスを使用してプロセッサステップでレコードを処理しようとしています。これらのクラスは並行して動作できます。現在、私はプロセッサクラスのI セット入力と出力行がサービスは将来のすべてのオブジェクトを取得し、最終的な出力を集めるエグゼキュータに提出し、マルチスレッド・ステップを書かれていますtaskExecutorを追加して仕事を並行させるとすぐに、手順1で設定した入力オブジェ

0熱

1答えて

ファンアウトアウトカラーストリーム処理を同時に行う方法

Akka Streamsを使用して、一連の依存ストリームを同時に処理しようとしています。このような何か： val concurrency = 2 Source( (1 to 5).toStream.map(i => { println(s"1: Emitting $i") i.toString })) .mapAsyncUnordered(con

1熱

1答えて

セロリ：同じキューの各</li> </ol><p>並行処理2と並行性4または労働者と</p> <ol><li>1つのワーカー：を有するの違いは何同時実行

対労働者の数。ありがとうございました

1熱

1答えて

Little Law's：Concurrency

私はこの質問をGoogleフォーラムに投稿しましたが、決定的な回答は得られませんでした。ロックの文脈でリトルの法則についての私の理解が正しいかどうかを誰かが確認できますか？ロックを取得して仕事をしてリリースするシステムがあるとします。さらに、「仕事」をするのに時間がかからないとします。 λ = L/ W (λ = throughout, L=Average number of custome

4熱

1答えて

コールスタックの最後の変数を作成する

私はいくつかのフィールドを含むクラスを持っています。私はこのクラスのインスタンスを値で比較する必要があるので、GetHashCodeとEqualsをそれに応じて定義しました。クラスは循環参照を許可するので、無限再帰を避けるためのメカニズムが必要です（詳細はValue-equals and circular references: how to resolve infinite recursion?

1熱

1答えて

のJavaロック条件

は、私は次のコードがあるとします。今 private final ReentrantLock resourcesLock = new ReentrantLock(true); private Condition resourcePresentCondition= resourcesLock.newCondition(); public void requestRes() throws Int

2熱

2答えて

ゴルーチンがブロックされているかどうかをランタイムチェックで調べる方法はありますか？

ゴーのドキュメントは言うこと：、彼らが勝ったので、このようなブロッキングシステムコールを呼び出すのと同じコルーチンブロックは、実行時には自動的に別の、実行可能なスレッドに同じオペレーティング・システム・スレッド上の他のコルーチンを動かしますブロックされないしかし、実行時にゴルーチンがブロックされていることをどのように検出するのですか？たとえば、go-routineの1つで計算を実行すると、ブ