Executors 工具类 创建 的 线程池

2018-07-20    来源:open-open

容器云强势上线!快速搭建集群,上万Linux镜像随意使用
import java.util.concurrent.ExecutorService;  
import java.util.concurrent.Executors;  
import java.util.concurrent.ScheduledExecutorService;  
import java.util.concurrent.TimeUnit;  
  
public class ThreadPoolTest {  
    static int num = 100;  
    public static void main(String[] args) throws InterruptedException {  
        //固定线程数量的线程池,有任务就派空闲线程去执行,多余的任务等待  
        //ExecutorService  pool= Executors.newFixedThreadPool(3);  
        //根据任务需要,自动创建线程,且 前面已创建的线程,空闲时,可被复用  
        //ExecutorService  pool= Executors.newCachedThreadPool();  
        //单个线程,若执行期出现失败而终止此单个线程,则会建一个新线程来代替,运行任务  
        ExecutorService  pool= Executors.newSingleThreadExecutor();  
        //给线程池加 10条任务  
        for (int j= 0; j < 10; j++) {  
            final int task = j;  
            pool.execute(new Runnable() {  
                  
                @Override  
                public void run() {  
                    // TODO Auto-generated method stub  
                    for (int i=0; i < 10; i++) {  
                        System.out.println(Thread.currentThread().getName() + "--" +i  
                                + "--" + task + " of taks" + " 计数:" + (--num));  
                    }  
                }  
            });  
            // Thread.sleep(20);  
        }  
        //可安排在给定的延迟后运行或定期执行的命令。   
        ScheduledExecutorService service = Executors.newScheduledThreadPool(3);  
        for (int i = 0; i < 5; i++) {  
            final int x = i;  
            service.scheduleAtFixedRate(new Runnable() {  
                  
                @Override  
                public void run() {  
                    // TODO Auto-generated method stub  
                    System.out.println("Boon " + x + "  "  + Thread.currentThread().getName());  
                }  
            },0,2,TimeUnit.SECONDS);//延迟0秒,周期2秒  
        }  
          
        //poor.shutdownNow();//试图马上停了所有正在执行的任务,返回任务列表  
        pool.shutdown();//把分配给线程池的任务都执行完,就不再等待接受新任务了,  
    //  service.shutdown();  
          
    }  
}

标签:

版权申明:本站文章部分自网络,如有侵权,请联系:west999com@outlook.com
特别注意:本站所有转载文章言论不代表本站观点!
本站所提供的图片等素材,版权归原作者所有,如需使用,请与原作者联系。

上一篇:C#发送带附件的邮件

下一篇:Android 一些功能代码