Executor多线程框架

啥都别说了，上代码：
import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.ThreadPoolExecutor;

public class ExecutorTest {

	private static Integer pages=1;

	private static boolean exeFlag=true;

	public static void main(String[] args) {

		ExecutorService executorService=Executors.newFixedThreadPool(10);//创建ExxcutorService线程池

		while(exeFlag){

			if(pages<=100){

				executorService.execute(new Runnable(){

					@Override

					public void run() {

						// TODO Auto-generated method stub

						System.out.println("爬取了第"+pages+"网页....");

						pages++;

					}

				});

			}else{

				if(((ThreadPoolExecutor)executorService).getActiveCount()==0){

					//活动线程个数为o

					executorService.shutdown();

					exeFlag=false;

					System.out.println("爬虫任务已经完成");

				}

			}

			try {

				Thread.sleep(100);

			} catch (InterruptedException e) {

				// TODO Auto-generated catch block

				e.printStackTrace();

			}

		}

	}

}
巴特西

Executor多线程框架

最新文章

热门文章
