シングルスレッド実行を適切に管理する方法は？

Question

私は、さまざまなソースによってトリガーされるプロセスを持っています。

特定の条件下で他のプロセス（「manualStarter」と呼ぶ）がこのメインプロセスをトリガーしたい場合があるとします。メインプロセスには10秒〜10分かかるとします。 manualStarterが起動しようとしている間にプロセスがすでに進行中の場合は、複数回キューに入れてはいけません。メインプロセスの開始をトリガする2つ目のプロセスは、プロセスを一時的にトリガする「timedStarter」でもかまいませんが、プロセスが実行されていない場合にのみ実行されます。それはしばらくしてからもう一度。

これでisAlive（）とjoin（）を使用してこの種のプロセスマネージャを実装しようとしましたが、isAlive（）は状態が生き残るまで、スレッドが開始されることがあります。だから私はそれに頼ることができなかったようだ。

次に、私が探しているものに近いところにあるSingleThreadExecutorサービスを試してみました。何もブロックしていないし、単一のスレッドしかプロセスを実行できないので、ステータスをチェックしたり、それを正しくロックしたり、スレッドを開始するキューが1より大きくならないようにするにはどうすればいいですか？私はセマフォがよく似たような種類のタスクに使用されていることを少しは読んだが、私はこのシナリオでどのように使用できるのでしょうか。

どのようにして私が望むものを達成することができますか？私自身のThreadPoolExecutorを実装する必要がありますか？どうしたらいいですか？もっと良い方法はありますか？

Answer 1

スレッドが実行されているかどうかを手動で確認できるように共有フラグを使用してください。例えば：あなたは、スレッドのためのあなたの所望の特性を達成するためにロックを使用して、同期して、いくつかのフラグを使用することができます

ScheduledExectorService sched = Executors.newScheduledThreadPool(1); 
ManualStarter starter = new ManualStarter(); 
// Every 10 seconds will check if MainProcess is running and will start 
// it if it's not 
sched..scheduleAtFixedRate(starter, 0, 10, SECONDS); 

Answer 2

代わりにExecutorServiceを使用する必要があります。利用可能な実装がいくつかあります（ScheduledExecutorServiceなど）。これにより、defferedおよび/または繰り返されるタスクのスケジュールを設定できます（チェックExecutors）。あなたの最善のニーズに合ったものを選んでください。

条件付き実行に関しては、タスクは単純です。与えられたタスクの現在の "状態"を保持する、ある種のアクセス可能なフラグを定義します。実行中の場合は、何も実行しないでください。実行をスケジュールします。

簡単な例：任意のハウツーのために

//our flag 
private volatile AtomicBoolean isRunning=new AtomicBoolean(false); 

public void scheduleTask(){ 
    if(isRunning.get()){ 
     return; // do nothing 
}else{ 
    synchronized(isRunning){ 
    if(isRunning.get()){ 
     return; 
}else{ 
    isRunning.set(true) 
    scheduleNewTask(); 
} 
} 
} 
} 

は、私が「可変」ブール値を模擬するために、この例ではAtomicBooleanを使用していofficial Oracle's documentaion about Executors. をご確認ください。 booleanで行うこともできますが、別のオブジェクトで同期を行う必要があります（例えば、private Object lock=new Object();）