スレッドプールを作成する 4 つの方法とは何ですか?-＆＃＆ベース-php.cn

スレッドプールを作成する 4 つの方法とは何ですか?

青灯夜游

リリース： 2023-01-13 00:39:43

オリジナル

34404 人が閲覧しました

メソッド: newCachedThreadPool はキャッシュ可能なスレッドプールを作成し、newFixedThreadPool は固定長のスレッドプールを作成し、newScheduledThreadPool は固定長のスレッドプールを作成し、newSingleThreadExecutor はシングルスレッドスレッドプールを作成します。

スレッドプールを作成する 4 つの方法とは何ですか?

#スレッドプールを作成する 4 つの方法

Java はエグゼキュータープールを通じて 4 つのスレッドを提供します、それぞれ:

1. newCachedThreadPool

newCachedThreadPool を使用して、キャッシュ可能なスレッドプールを作成します。スレッドプールの長さが処理の必要性を超えた場合、アイドル状態のスレッドを柔軟にリサイクルできます。 . リサイクルがない場合は、新しいスレッドを作成してください。

このタイプのスレッドプールの特徴は次のとおりです。

作成されるワーカースレッドの数にはほとんど制限がありません (実際には制限があります。数値は整数.MAX_VALUE) なので、スレッドプールにスレッドを柔軟に追加できます。
タスクがスレッドプールに長期間送信されない場合、つまり、ワーカースレッドが指定された時間 (デフォルトは 1 分) アイドル状態である場合、ワーカースレッドは自動的に終了します。終了後に新しいタスクを送信すると、スレッドプールはワーカースレッドを再作成します。
CachedThreadPool を使用する場合は、タスク数の制御に注意しないと、同時に多数のスレッドが実行され、システムが麻痺する可能性があります。

サンプルコードは次のとおりです:

 package test;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
   public class ThreadPoolExecutorTest {
   public static void main(String[] args) {
   ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
  for (int i = 0; i < 10; i++) {
   final int index = i;
    try {
    Thread.sleep(index * 1000);
    } catch (InterruptedException e) {
     e.printStackTrace();
    }
    cachedThreadPool.execute(new Runnable() {
     public void run() {
      System.out.println(index);
     }
    });
   }
  }
 }

ログイン後にコピー

2. newFixedThreadPool

を使用して、指定されたスレッドプールを作成します。ワーカースレッドの数。タスクがサブミットされるたびにワーカースレッドが作成され、ワーカースレッドの数がスレッドプールの初期最大数に達すると、サブミットされたタスクはプールキューに格納されます。

FixedThreadPool は典型的な優れたスレッドプールであり、スレッドプールによってプログラムの効率が向上し、スレッド作成時のオーバーヘッドが節約されるという利点があります。ただし、スレッドプールがアイドル状態のとき、つまりスレッドプールに実行可能なタスクがないときは、ワーカースレッドは解放されず、特定のシステムリソースも占有します。

サンプルコードは次のとおりです。

 package test;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 public class ThreadPoolExecutorTest {
  public static void main(String[] args) {
   ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
   for (int i = 0; i < 10; i++) {
    final int index = i;
    try {
     Thread.sleep(index * 1000);
    } catch (InterruptedException e) {
     e.printStackTrace();
    }
    cachedThreadPool.execute(new Runnable() {
     public void run() {
      System.out.println(index);
     }
    });
   }
  }
 }

ログイン後にコピー

スレッドプールサイズが 3 であるため、各タスクはインデックスの出力後に 2 秒間スリープし、2 秒ごとに 3 つの数値が出力されます。

固定長スレッドプールのサイズは、Runtime.getRuntime().availableProcessors() などのシステムリソースに応じて設定するのが最適です。

3. newSingleThreadExecutor

を使用してシングルスレッド Executor を作成します。つまり、タスクを実行するための一意のワーカースレッドのみを作成します。これは唯一のワーカーのみを使用します。タスクを実行するには、すべてのタスクが指定された順序 (FIFO、LIFO、優先順位) で実行されるようにしてください。このスレッドが異常終了した場合は、順次実行を保証するために別のスレッドに置き換えられます。単一ワーカースレッドの最大の特徴は、タスクが順番に実行され、同時に複数のスレッドがアクティブになることがないことを保証できることです。

サンプルコードは次のとおりです:

package test;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ThreadPoolExecutorTest {
 public static void main(String[] args) {
  ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();
  for (int i = 0; i < 10; i++) {
   final int index = i;
   singleThreadExecutor.execute(new Runnable() {
    public void run() {
     try {
      System.out.println(index);
      Thread.sleep(2000);
     } catch (InterruptedException e) {
      e.printStackTrace();
     }
    }
   });
  }
 }
}

ログイン後にコピー

4. newScheduledThreadPool

を使用して、固定長のスレッドプールを作成し、スケジュールされた定期的なタスクをサポートします。実行。スケジュールされた定期的なタスクの実行をサポートします。

実行を 3 秒遅延します。遅延実行のサンプルコードは次のとおりです。

package test;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class ThreadPoolExecutorTest {
 public static void main(String[] args) {
  ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5);
  scheduledThreadPool.schedule(new Runnable() {
   public void run() {
    System.out.println("delay 3 seconds");
   }
  }, 3, TimeUnit.SECONDS);
 }
}

ログイン後にコピー

は、1 秒の遅延後に 3 秒ごとに実行されることを意味します。定期実行のサンプルコード

package test;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class ThreadPoolExecutorTest {
 public static void main(String[] args) {
  ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(5);
  scheduledThreadPool.scheduleAtFixedRate(new Runnable() {
   public void run() {
    System.out.println("delay 1 seconds, and excute every 3 seconds");
   }
  }, 1, 3, TimeUnit.SECONDS);
 }
}

ログイン後にコピー

続きプログラミング関連の知識については、

プログラミング学習 Web サイトをご覧ください。！

以上がスレッドプールを作成する 4 つの方法とは何ですか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。