futuretask

0熱

1答えて

Akka-Java：パイプパターンを使用して親の将来のメッセージを受け取ることができません

1つの親に対して1つの子アクターを作成しています。私の子供の俳優は、いくつかのビジネスロジックを実行し、scala Futureに価値を返します。親にFutureメッセージを送信すると、私は将来のメッセージをキャッチできません。以下は、私のコードです： 子役 public class FetchDevicesIds extends AbstractActor { private final L

java scala akka futuretask akka-supervision 2016-08-21

---

-3熱

1答えて

Java：未来を追加する<obj>をリストに追加する

オブジェクトを並行して取得することができたので、これらのオブジェクトをリストに追加するにはどうすればよいですか？ ArrayListのSiteオブジェクトに追加しようとしているオブジェクトのリストがあります。Future<Site>ここに私のforループがあります。ループ内にprintステートメントを追加すると、Future<Site>オブジェクトのリストが実際に埋め込まれていることがわかりますが

java java-8 future futuretask 2016-09-01

---

5熱

1答えて

javaで将来のタスクをキャンセルする

ExecutorServiceに送信されたタスクをキャンセルして、対応するスレッドがキューから新しいタスクを選択できるようにします。 この質問はこのフォーラムで何度も答えられています.... Thread.currentThread().interrupt()またはcatch (InterruptedException e)のようにチェックしてください。しかし、コントロールの流れが複数の方法にまた

java multithreading exception executorservice futuretask 2017-07-03

---

1熱

1答えて

1.8で呼び出し可能なfuturetaskを使用して実行中のタスクを完全に終了させる方法

スレッドで実行できる特定のプロセスがあります。特定の時間が経過すると処理を完全に停止する必要があります。例：90秒。 将来、スレッドのタイムアウトを設定するオプションがあります。しかし、私はタイムアウト例外が発生しているが、開始タスクはバックエンドで実行されている、それは完全にfutureTask.cancel(true)またはexecutor.isShutdown()を使用して停止されていません

java multithreading timeout callable futuretask 2017-03-27

---

0熱

2答えて

ThreadPoolExecutor特定のタスクが待ち行列に入っているかどうかを確認します

私はシリアル接続を1つのスレッドだけが使用します。しかし、エグゼクティブに新しいタスクを提出する前に、特定のタスクがすでにキューに入っているかどうかチェックしたい（たとえばポーリング値）。 executor = (ThreadPoolExecutor) Executors.newFixedThreadPool(1); new Thread(new Runnable() { @Ove

java future executorservice threadpoolexecutor futuretask 2016-06-02

---

0熱

2答えて

将来と非同期

私は私が私が将来 ... for (Layer layer : layers) { // ListenableFuture extends Future<V> final ListenableFuture<FeatureQueryResult> future= gdbFeatureTable.queryFeaturesAsync(query); future.addDoneListen

android asynchronous futuretask esri-arc-engine 2017-12-05

---

-1熱

1答えて

ResultSetFutureでコレクションを変更する

java-driver-async-queriesを使用して非同期クエリを実装しようとしました。 FutureCallback内のリストを変更していますが、機能していないようです - List<Product> products = new ArrayList<Product>(); for (// iterating over a Map) { key = entry.getKey

java cassandra datastax futuretask 2017-08-29

---

0熱

1答えて

AsynFutureを呼び出すJavaのスレッド間でオブジェクトを共有する

私はいくつかのタスクを実行する実行可能クラスAを作成しました。これらのタスクを並行して実行できるように、ExecutorServiceを使用してこのクラスを送信しています。 実行可能クラスAは、AsyncFutureリクエスト（future.get（）1）を送信する別のオブジェクトBを呼び出します。 RunnableクラスAのオブジェクトをExecutorServiceに送信しますが、クラスBのオ

java spring multithreading executorservice futuretask 2016-11-09

---

0熱

4答えて

一意のオブジェクトのキャンセル可能なスレッドマネージャを実装します

オブジェクトをキーとして何かを行う多くのバックグラウンドスレッドを管理する必要がありますが、同じオブジェクトで同時に実行できるスレッドは1つだけです。例えば、thread Aはobject A、 thread Bとobject Aとの作業が必要な場合は、thread Bを実行する前にthread Aをキャンセルする必要があります。ここで は私のコードですが、私が実行したときに、最初のスレッドが停止

java android multithreading executorservice futuretask 2016-06-16

---