ExecutorserviceはJavaでどのように動作しますか？

Question

私は伝統的なスレッドの実装に精通していますが、Executorserviceについてはあまりよく分かりません。私はexecutorサービスを使ってスレッドを扱うときにとても便利だと知っています。しかし、私はその実装についてほとんど混乱していません。

私は親スレッド/メインスレッドと最大スレッドプールサイズ10を持つExecutorサービスを持っているとしましょう。今は、サイズが1000未満の場合にのみjmsキューで特定のタスクを実行したいと思います。おそらく2つの方法でこれを実装すると思います。

ケース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"); 
     } 
} 

ケース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; 
        } 
       } 
      } 
    } 

私の理解では、複数のスレッドにまたがるませんケース2です。私は正しいかどうか？または、タスクを実行する別の方法がありますか？

Answer 1

「ケース2は複数のスレッドにまたがることはありません」はい。これは正しいです。 executeに一度だけ電話するからです。

最初のシナリオでは、executeに何度も電話することができます。以前のタスクが完了していない場合は、追加のスレッドが実行されます。

Answer 2

私のコードを見つけてください： -

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"); 
       } 
      } 
     } 
    } 

修正： -

1. 10個のスレッドを作成してのRunnableクラスオブジェクトを渡すことで、ジョブを実行するためにそれらを割り当てます。
   2. 無限ループを外側ループとして削除し、無限ループを実行します。