ホームページ >Java >&#&チュートリアル >Executor マルチスレッド フレームワークの使用方法 (例付き)
この記事の内容は、Executor マルチスレッド フレームワークの使用方法に関するものです (例付き)。必要な方は参考にしていただければ幸いです。
JDK1.5 では、JAVA は、マルチスレッド アプリケーションの開発をより便利にするためにカプセル化されたフレームワーク (Executor) を開始しました。従来の Thread クラスと比較して、Executor はより便利で、より優れたパフォーマンスを備えています。管理が簡単で、スレッド プールをサポートします。一般に、クローラーを開発する場合、クローラーの効率を向上させるためにマルチスレッドが必要であり、Executor は非常に良い選択肢です。
共通インターフェイス:
1) 固定数のスレッドでスレッド プールを作成します:
public static ExecutorService newFixedThreadPool(int nThreads)
2)スレッドを実行します
void java.util.concurrent.Executor.execute(実行可能なコマンド)
3) 現在のアクティブなスレッド数を表示します
int java.util.concurrent .ThreadPoolExecutor.getActiveCount ()
4) すべてのスレッドを終了します
void java.util.concrrent.ExecutorService.shutdonw()
Executor は複数のスレッドを管理するときに有効になります。配置。たとえば、スレッド プールの作成時にスレッド プールに 10 個のスレッドがある場合、スレッドを実装するために 10 個を超えるエグゼキュータを追加すると、効果的なキューのブロックとスケジューリングが実行されます。私たち開発者にとって、これは透過的であり、内部でどのように動作するかを気にする必要はありません。
コード例:
package com.java.executor; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.ThreadPoolExecutor; public class ExecutorTest { private static Integer count = 1; //数量 private static boolean flag = true;//是否执行 public static void main(String[] args) { ExecutorService executorService = Executors.newFixedThreadPool(10);//在连接池中初始化10个线程 while(flag){ if(count<=100){ executorService.execute(new Runnable() { @Override public void run() { System.out.println("执行 : " + count++); } }); }else{ //判断是否有活动线程 if(((ThreadPoolExecutor)executorService).getActiveCount()==0){ executorService.shutdown();//结束所有线程 flag=false; System.out.println("完成操作"); } } try { Thread.sleep(100);//休息0.1秒 } catch (InterruptedException e) { e.printStackTrace(); } } } }
これは Executor を使用する簡単な方法で、便利で高速で、習得も簡単です。ここで休憩を取る 0.1 秒単位で言えば、カウントが 100 を超えるまでこのコードで休まないと、スレッドはアクティブのままになり、スレッドが停止します。さらに、スレッドの実行速度は非常に高速であり、この速度を使用してクローラーが Web を巡回すると、IP がブロックされやすくなります。
以上がExecutor マルチスレッド フレームワークの使用方法 (例付き)の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。