基本的に Callable クラスである MyTask と呼んでいます。言う:
public class MyTask implements Callable
{
// my custom code which returns from call()
}
public class Worker
{
ExecutorService service = Executors.newSingleThreadExecutor();
}
Worker クラス内に singleThreadpoolExecutorService があります。これは、worker クラスが呼び出されたときの初期化時に開始する必要があります。
そして、オブジェクトに MyTask を送信するまで、サービスは実行し続ける必要があります....実行すると、呼び出し可能の結果が返されます。
さて、私の問題は、
サービスは実行し続け、将来のオブジェクトの形で入力を受け入れ続ける必要があります。そしてそれを実行し、結果を出します。サービスが途中で停止しないようにするにはどうすればよいですか。
isShutDownなどの外部フラグから呼び出されたときに、サービスを停止する必要があります。
助けていただけますか?
ありがとうございました。