future

7熱

2答えて

私はScalaの将来の結果をを待つがを受けるよりのように、それは振る舞うない、またははを反応させるように利用可能な場合、すなわち、それは結果の後、スレッド、またはスケジュールの継続をブロックしますか？

3熱

3答えて

私はスレッドプールで多くのジョブを実行する必要があるC++プロジェクトに取り組んでいます。ジョブは失敗する傾向があります。つまり、完了後に各ジョブがどのように終了するかを知る必要があります。 Javaプログラマーの大部分は、Javaのutil.concurrentパッケージのさまざまなクラスに似た、 "先物"や同様のパラダイムを使用する考えが好きです。私は2つの質問があります：まず、これは既にC

1熱

1答えて

ブーストスレッド先物のベクトルを使用するにはどうすればよいですか？

スレッドのフューチャのベクトルを使用して、スレッドのグループから戻り値を取得するにはどうすればよいですか？これはうまくいくはずですか？そうでない場合は、どのようにそれを適応させるのですか？ int calculate_the_answer_to_life_the_universe_and_everything() { return 42; } vector<packaged_ta

2熱

1答えて

Akka/future - Akkaは、現在のスレッドまたはディスパッチャを使用して "価値がある"かどうかを判断しますか？

私は現在、いくつかのFutureを作成してBlockingQueueに入れるというタスクを達成するためにAkka（Java API /ライブラリ）を使用することを考えています。今度は、新しいスレッドを作成するか、新しいスレッドが利用可能になるのを待つのではなく、Callableによって処理されるいくつかのタスクが、呼び出しスレッドで高速/高速で実行されることがあります。 Future<String

7熱

1答えて

Akkaを使用したフォーク＆ジョイン

問題文：私は、並列に処理する必要がある有価証券のポートフォリオを持っています。 Javaでは、私は各セキュリティを処理するためにスレッドプールを使用し、カウントダウンにラッチを使用します。完了したら、いくつかのマージなどを行います。私はSecurityProcessor（アクター）にメッセージを送り、すべての未来が完了するのを待ちます。最後に、MergeHelperを使用して後処理を行います。

0熱

1答えて

Linq to NHibernate + transformations + future

私はあなたが.ToFuture <>（）拡張メソッドを呼び出すことによって将来的にNHibernateクエリにLinqを実行できることを知っています。しかし、私はマッピングされたエンティティを読み込むのではなく、データをDTOに直接ロードします。 var results = (from e in session.Query<Entity>() where e.Reference.I

3熱

3答えて

マルチスレッド検索操作

クエリの配列を取るメソッドがあり、GoogleやYahooなどのさまざまな検索エンジンWeb APIに対してそれらを実行する必要があります。プロセスを並列化するために、クエリが毎回joinになるスレッドが生成されます。の後にはとなります。の結果はとなります。 public abstract class class Query extends Thread { private String

5熱

3答えて

CompletionServiceを使用して長すぎるタスクをキャンセルするには

CompletionServiceを使用していくつかのFutureタスクを送信します。FixedThreadPool ExecutorService 2スレッドをラップして、設定したタスクの数と等しいループを設定し、completionserviceを使用します。それらをすべて完了または失敗させるのを待つtake（）。私はtake（）メソッドをpoll（300、Timeout.SECONDS）に変

1熱

2答えて

私の一般的なFutureの実装にはCompletedイベントが必要ですか？

私は非同期的に値を取得してカプセル化し、私はウェブ上で最も既存の実装は、このような契約を持って気づいたジェネリックFuture<T>クラス書いている： public class Future<T> { public Future(Func<T> func); // kicks off the async operation public T Value { get; } //

2熱

2答えて

set_value（）を反転して約束を無効にするにはどうしたらいいですか？

ここでは、同期に関する合計n00bの質問があります。私は、それぞれの繰り返しで約束に別の値 'p'を割り当てる 'writer'スレッドを持っています。私はこの値のshared_futuresを待つ「読者」スレッドが必要です。そして、私の質問は、読者スレッドが 'p'の新しい更新を待つことを保証するためにfuture/promiseをどうすれば使うのですか？各反復？どうもありがとう。