Thread Executor: läuft mehrere Prozesse und Pool warten 30 Minuten vor dem nächsten Prozess

Question

Derzeit arbeite ich Multiprozessoring mit ThreadPoolExecutor API implementieren. Nachfolgend ist die Anforderung zu verarbeiten:

1. Definierte Nr. von Java-Prozess zu einem Zeitpunkt unter Verwendung von Threadpool mit ExecutorService executor = Executors.newFixedThreadPool(3);

2. und ich bin die Einreichung aller eigentlichen Prozesses des runnable jar Prozesses zu laufen zu bündeln ist

   for(int i=1; i<50; i++) { 
       RunnableTask r=new RunnableTask(); 
       executor.submit(r); 
   } 
   

und tatsächliche RunnableTask folgt

public class RunnableTask implements Runnable{ 
    public void run(){ 
    Process p=Runtime.exec("java -jar D:\ProcessIntiate.jar"); 
} 

Jetzt, wenn der Pool gestartet wird, wird nur 3 Prozess parallel gestartet.

Ich möchte nur 3 Prozesse gleichzeitig ausführen und nach Abschluss von 3 Prozess muss mein Pool 30 Minuten warten und muss die nächsten 3 Prozesse starten. Außerdem muss eine Benachrichtigung zum Pooling erforderlich sein, wenn alle 3 Prozesse abgeschlossen sind.

Gibt es eine Möglichkeit mit ThreadExcutorFramwork?

Answer 1

Eine einfache Lösung: Fügen Sie Ihrem Runnable-Code einfach 30 Minuten Wartezeit hinzu.

Oder besser: geben Sie dem Runable einen Parameter, der steuert, wie lange es wartet. Für die ersten 47 Prozesse geben Sie 30 Minuten; und dann 0.

Alternativ einfach nicht 50 Aufgaben vorlegen. Stattdessen: Verwenden Sie einen äußeren Thread, der 3 Aufgaben schiebt und dann wartet/schläft, bis diese 3 erledigt sind. Dann warten Sie 30 Minuten und drücken Sie eine andere 3.

Answer 2

Statt die Anfrage direkt an Thread-Pool zu senden, speichern Sie es in einer Sammlung.

Verwenden Sie einen ScheduledExecutorService mit der Größe 1, um eine Aufgabe zu planen, die nach einem bestimmten Intervall ausgeführt wird (in Ihrem Fall etwa 30 Minuten).

Er übernimmt die Aufgabe aus der Sammlung im Stapel und übergibt sie an einen anderen Pool, wo er tatsächlich so programmiert ist, dass er die übergebene Aufgabe verarbeitet.

class CustomScheduledExecutor { 
ScheduledExecutorService scheduleExecutor = Executors.newScheduledThreadPool(1); 
ExecutorService executorService = Executors.newFixedThreadPool(3); 

Queue<Runnable> queue = new ConcurrentLinkedQueue<Runnable>(); 

public CustomScheduledExecutor(){ 
    scheduleExecutor.scheduleWithFixedDelay(new Runnable() { 

     @Override 
     public void run() { 
      for(int i=0;i<3;i++){ 
       Runnable poll = queue.poll(); // Do the handling for queue size 
       executorService.submit(poll); 
      } 
     } 
    }, 1000, 30, TimeUnit.MINUTES); 
} 

public void submitTask(Runnable runnable){ 
    queue.offer(runnable); 
} 

} 

Senden auch zukünftige Instanzen zurück, so haben Sie eine Kontrolle über die übergebene Aufgabe und kann nach Bedarf manipulieren.