Wie funktioniert der Executorservice in Java?

Question

Ich bin vertraut mit der traditionellen Thread-Implementierung, aber nicht so sicher über Executorservice. Ich weiß, dass es sehr praktisch ist, wenn man Threads mit dem Executor-Service behandelt. Aber ich bin etwas verwirrt über die Implementierung.

Nehmen wir an, ich habe einen übergeordneten Thread/Hauptthread und einen Executor-Service, der max Thread-Poolgröße 10 hat. Jetzt möchte ich eine bestimmte Aufgabe auf einer JMS-Warteschlange nur ausführen, wenn ihre Größe weniger als 1000 ist Ich kann wahrscheinlich denken, dies auf zwei Arten zu implementieren.

Fall 1:

class MyThreadClass inmplements Runnable { 
     public static void main(String args[]){ 
      while(true){ 
       int checkQueueSize = jmsQueue.getSize(); 
       while(checkQueueSize<1000){ 
        threadPoolTaskExecutor.execute(this); 
        ++checkQueueSize; 
       } 
      } 
     } 
     public void run(){ 
      jmsQueue.pushMessage("Hello Thread"); 
     } 
} 

Fall 2:

class MyThreadClass inmplements Runnable { 
      public static void main(String args[]){ 
      threadPoolTaskExecutor.setWaitForTasksToCompleteOnShutdown(true); 
       threadPoolTaskExecutor.execute(this); 
      } 
      public void run(){ 
       while(true){ 
        int checkQueueSize = jmsQueue.getSize(); 
        while(checkQueueSize<1000){ 
         jmsQueue.pushMessage("Hello Thread"); 
         ++checkQueueSize; 
        } 
       } 
      } 
    } 

Mein Verständnis ist Fall 2 wird nicht mehr als ein Thread überspannen. Bin ich richtig oder nicht? Oder gibt es eine andere Möglichkeit, die Aufgabe auszuführen?

Answer 1

"Fall 2 wird nicht mehr als einen Thread umfassen" Ja. Das ist richtig. Weil Sie execute nur einmal anrufen. Im ersten Szenario können Sie oft execute aufrufen. Und wenn die vorherige Aufgabe nicht abgeschlossen ist, wird zusätzlicher Thread unrundiert.

Answer 2

Bitte meinen Code finden: -

class MyThreadClass inmplements Runnable { 
     public static void main(String args[]){ 
      threadPoolTaskExecutor.setWaitForTasksToCompleteOnShutdown(true); 
      for(int i=0;i<10;i++) 
      threadPoolTaskExecutor.execute(this); 
     } 
     public void run(){ 
      while(true){ 
       int checkQueueSize = jmsQueue.getSize(); 

       if(checkQueueSize<=1000){ 
        jmsQueue.pushMessage("Hello Thread"); 
       } 
      } 
     } 
    } 

Modifikation: -

1. die 10 Threads erstellen und ordnen diese Aufgabe auszuführen, indem Sie Ihre Runnable-Klasse-Objekt übergeben.
   2. Entfernen Sie unnötige While-Schleife als die äußere Schleife, die infite Iteration durchführt.