欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Executor多线程框架使用

程序员文章站 2022-05-25 14:36:44
在我们的JDK1.5的时候JAVA推出一款为了更加方便开发的多线程应用而封装的框架(Executor),相比传统的Thread类,Executor更加的方便,性能好,更易于管理,而且支持线程池。一般在开发爬虫的时候为了提供爬虫的效率,需要使用多线程,而Executor就是一个非常不错的选择。 常用接 ......

在我们的jdk1.5的时候java推出一款为了更加方便开发的多线程应用而封装的框架(executor),相比传统的thread类,executor更加的方便,性能好,更易于管理,而且支持线程池。一般在开发爬虫的时候为了提供爬虫的效率,需要使用多线程,而executor就是一个非常不错的选择。

常用接口:

1)创建固定数目线程的线程池:

public static executorservice newfixedthreadpool(int nthreads)

2)执行一个线程

void java.util.concurrent.executor.execute(runnable command)

3)查看当前活动线程个数

int java.util.concurrent.threadpoolexecutor.getactivecount()

4)结束掉所有的线程

void java.util.concrrent.executorservice.shutdonw()

executor在管理多个线程的时候会进行有效的安排。处理,比如创建的时候线程池里有10个线程,加入实现线程超过10个executor会进行有效的队列阻塞和调度。对于我们开发者开说这是透明的,完全不需要关心它内部是怎么进行的操作。

实例代码:

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秒呢,在上面这段代码上我们是没有加锁的,如果不休息在这段代码上等count大于100的时候,线程还在活动中会导致线程没有进行关闭,加上线程执行速度的飞快会超过我们需求,并且在爬虫爬网页的时候使用这么块的速度是很容易封ip的。