AI 助理
文档备案控制台
开发者社区 开发与运维 文章 正文

Java:使用Executors创建和管理线程

2017-11-16 1022
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：
1.  类  Executors

此类中提供的一些方法有：
1.1 public static ExecutorService newCachedThreadPool()

创建一个可根据需要创建新线程的线程池，但是在以前构造的线程可用时将重用它们。对于执行很多短期异步任务的程序而言，这些线程池通常可提高程序性能。
 
1.2 public static ExecutorService newFixedThreadPool(int nThreads)

创建一个可重用固定线程数的线程池，以共享的无界队列方式来运行这些线程。
 
1.3 public static ExecutorService newSingleThreadExecutor()

创建一个使用单个  worker  线程的  Executor ，以无界队列方式来运行该线程。
 
这三个方法都可以配合接口 ThreadFactory 的实例一起使用。并且返回一个 ExecutorService 接口的实例。
2.  接口  ThreadFactory

根据需要创建新线程的对象。使用线程工厂就无需再手工编写对  new Thread  的调用了，从而允许应用程序使用特殊的线程子类、属性等等。
此接口最简单的实现就是：
class SimpleThreadFactory implements ThreadFactory {
   public Thread newThread(Runnable r) {
     return new Thread(r);
   }
 }
3.  接口 ExecutorService

该接口提供了管理终止的方法。
4. 创建标准线程池启动线程

4.1  提供一个简单的实现 Runnable 接口的线程

MyThread.java

package  com.zj.concurrency.executors;

 

public   class  MyThread  implements  Runnable {

     private   int   count  = 1,  number ;

 

     public  MyThread( int  num) {

        number  = num;

       System. out .println( "Create Thread-"  +  number );

    }

 

     public   void  run() {

        while  ( true ) {

           System. out .println( "Thread-"  +  number  +  " run "  +  count + " time(s)" );

            if  (++ count  == 3)

               return ;

       }

    }

}
这个线程会打印出相应的创建和执行信息。
 
4.2 使用 CachedThreadPool 启动线程

CachedThreadPool.java

package  com.zj.concurrency.executors;

import  java.util.concurrent.ExecutorService;

import  java.util.concurrent.Executors;

 

public   class  CachedThreadPool {

     public   static   void  main(String[] args) {

       ExecutorService exec = Executors.newCachedThreadPool();

        for  ( int  i = 0; i < 5; i++)

           exec.execute( new  MyThread(i));

       exec.shutdown();

    }

}
结果：
Create Thread-0

Create Thread-1

Create Thread-2

Create Thread-3

Thread-0 run 1 time(s)

Thread-0 run 2 time(s)

Thread-1 run 1 time(s)

Thread-1 run 2 time(s)

Thread-2 run 1 time(s)

Thread-2 run 2 time(s)

Create Thread-4

Thread-4 run 1 time(s)

Thread-4 run 2 time(s)

Thread-3 run 1 time(s)

Thread-3 run 2 time(s)
 
4.3  使用 FixedThreadPool 启动线程

FixedThreadPool.java

package  com.zj.concurrency.executors;

import  java.util.concurrent.ExecutorService;

import  java.util.concurrent.Executors;

 

public   class  FixedThreadPool {

     public   static   void  main(String[] args) {

       ExecutorService exec = Executors.newFixedThreadPool(2);

        for  ( int  i = 0; i < 5; i++)

           exec.execute( new  MyThread(i));

       exec.shutdown();

    }

}
结果：
Create Thread-0

Create Thread-1

Create Thread-2

Create Thread-3

Create Thread-4

Thread-0 run 1 time(s)

Thread-0 run 2 time(s)

Thread-2 run 1 time(s)

Thread-2 run 2 time(s)

Thread-3 run 1 time(s)

Thread-3 run 2 time(s)

Thread-4 run 1 time(s)

Thread-4 run 2 time(s)

Thread-1 run 1 time(s)

Thread-1 run 2 time(s)
 
4.4  使用 SingleThreadExecutor 启动线程

SingleThreadExecutor.java

package  com.zj.concurrency.executors;

import  java.util.concurrent.ExecutorService;

import  java.util.concurrent.Executors;

 

public   class  SingleThreadExecutor {

     public   static   void  main(String[] args) {

       ExecutorService exec = Executors.newSingleThreadExecutor();

        for  ( int  i = 0; i < 5; i++)

           exec.execute( new  MyThread(i));

       exec.shutdown();

    }

}
结果：
Create Thread-0

Create Thread-1

Create Thread-2

Create Thread-3

Create Thread-4

Thread-0 run 1 time(s)

Thread-0 run 2 time(s)

Thread-1 run 1 time(s)

Thread-1 run 2 time(s)

Thread-2 run 1 time(s)

Thread-2 run 2 time(s)

Thread-3 run 1 time(s)

Thread-3 run 2 time(s)

Thread-4 run 1 time(s)

Thread-4 run 2 time(s)
5. 配合 ThreadFactory 接口的使用

我们试图给线程加入 daemon 和 priority 的属性设置。
5.1 设置后台线程属性

DaemonThreadFactory.java

package  com.zj.concurrency.executors.factory;

import  java.util.concurrent.ThreadFactory;

 

public   class  DaemonThreadFactory  implements  ThreadFactory {

     public  Thread newThread(Runnable r) {

       Thread t =  new  Thread(r);

       t.setDaemon( true );

        return  t;

    }

}
 
5.2  设置优先级属性

最高优先级 MaxPriorityThreadFactory.java

package  com.zj.concurrency.executors.factory;

import  java.util.concurrent.ThreadFactory;

 

public   class  MaxPriorityThreadFactory  implements  ThreadFactory {

     public  Thread newThread(Runnable r) {

       Thread t =  new  Thread(r);

       t.setPriority(Thread. MAX_PRIORITY );

        return  t;

    }

}
最低优先级 MinPriorityThreadFactory.java

package  com.zj.concurrency.executors.factory;

import  java.util.concurrent.ThreadFactory;

 

public   class  MinPriorityThreadFactory  implements  ThreadFactory {

     public  Thread newThread(Runnable r) {

       Thread t =  new  Thread(r);

       t.setPriority(Thread. MIN_PRIORITY );

        return  t;

    }

}
 
5.3 启动带有属性设置的线程

ExecFromFactory.java

package  com.zj.concurrency.executors;

import  java.util.concurrent.ExecutorService;

import  java.util.concurrent.Executors;

import  com.zj.concurrency.executors.factory.DaemonThreadFactory;

import  com.zj.concurrency.executors.factory.MaxPriorityThreadFactory;

import  com.zj.concurrency.executors.factory.MinPriorityThreadFactory;

 

public   class  ExecFromFactory {

     public   static   void  main(String[] args)  throws  Exception {

       ExecutorService defaultExec = Executors.newCachedThreadPool();

       ExecutorService daemonExec = Executors

              .newCachedThreadPool( new  DaemonThreadFactory());

       ExecutorService maxPriorityExec = Executors

              .newCachedThreadPool( new  MaxPriorityThreadFactory());

       ExecutorService minPriorityExec = Executors

              .newCachedThreadPool( new  MinPriorityThreadFactory());

        for  ( int  i = 0; i < 10; i++)

           daemonExec.execute( new  MyThread(i));

        for  ( int  i = 10; i < 20; i++)

            if  (i == 10)

              maxPriorityExec.execute( new  MyThread(i));

            else   if  (i == 11)

              minPriorityExec. execute(new MyThread(i));

            else

              defaultExec.execute( new  MyThread(i));

    }

}
结果：
Create Thread-0

Create Thread-1

Create Thread-2

Create Thread-3

Thread-0 run 1 time(s)

Thread-0 run 2 time(s)

Thread-1 run 1 time(s)

Thread-1 run 2 time(s)

Thread-2 run 1 time(s)

Thread-2 run 2 time(s)

Create Thread-4

Thread-4 run 1 time(s)

Thread-4 run 2 time(s)

Create Thread-5

Thread-5 run 1 time(s)

Thread-5 run 2 time(s)

Create Thread-6

Create Thread-7

Thread-7 run 1 time(s)

Thread-7 run 2 time(s)

Create Thread-8

Thread-8 run 1 time(s)

Thread-8 run 2 time(s)

Create Thread-9

Create Thread-10

Thread-10 run 1 time(s)

Thread-10 run 2 time(s)

Create Thread-11

Thread-9 run 1 time(s)

Thread-9 run 2 time(s)

Thread-6 run 1 time(s)

Thread-6 run 2 time(s)

Thread-3 run 1 time(s)

Thread-3 run 2 time(s)

Create Thread-12

Create Thread-13

Create Thread-14

Thread-12 run 1 time(s)

Thread-12 run 2 time(s)

Thread-13 run 1 time(s)

Thread-13 run 2 time(s)

Create Thread-15

Thread-15 run 1 time(s)

Thread-15 run 2 time(s)

Create Thread-16

Thread-16 run 1 time(s)

Thread-16 run 2 time(s)

Create Thread-17

Create Thread-18

Create Thread-19

Thread-14 run 1 time(s)

Thread-14 run 2 time(s)

Thread-17 run 1 time(s)

Thread-17 run 2 time(s)

Thread-18 run 1 time(s)

Thread-18 run 2 time(s)

Thread-19 run 1 time(s)

Thread-19 run 2 time(s)

Thread-11 run 1 time(s)

Thread-11 run 2 time(s)


本文转自zhangjunhd51CTO博客，原文链接：http://blog.51cto.com/zhangjunhd/70068，如需转载请自行联系原作者
文章标签：
Java
关键词：
Java线程
executors线程
Java管理
Java Executors
线程管理
科技小先锋
目录
相关文章
凉凉心.
|
3月前
|
JSON 网络协议 安全
【Java】（10）进程与线程的关系、Tread类；讲解基本线程安全、网络编程内容；JSON序列化与反序列化
几乎所有的操作系统都支持进程的概念，进程是处于运行过程中的程序，并且具有一定的独立功能，进程是系统进行资源分配和调度的一个独立单位一般而言，进程包含如下三个特征。独立性动态性并发性。
凉凉心.
233 1
凉凉心.
|
3月前
|
JSON 网络协议 安全
【Java基础】（1）进程与线程的关系、Tread类；讲解基本线程安全、网络编程内容；JSON序列化与反序列化
几乎所有的操作系统都支持进程的概念，进程是处于运行过程中的程序，并且具有一定的独立功能，进程是系统进行资源分配和调度的一个独立单位一般而言，进程包含如下三个特征。独立性动态性并发性。
凉凉心.
246 2
小白学大数据
|
4月前
|
数据采集 存储 弹性计算
高并发Java爬虫的瓶颈分析与动态线程优化方案
高并发Java爬虫的瓶颈分析与动态线程优化方案
小白学大数据
276 1
Java 数据库 Spring
200 0
蓝易云
|
4月前
|
算法 Java
Java多线程编程：实现线程间数据共享机制
以上就是Java中几种主要处理多线程序列化资源以及协调各自独立运行但需相互配合以完成任务threads 的技术手段与策略。正确应用上述技术将大大增强你程序稳定性与效率同时也降低bug出现率因此深刻理解每项技术背后理论至关重要.
蓝易云
362 16
艾伦~耶格尔
|
5月前
|
缓存 并行计算 安全
关于Java多线程详解
本文深入讲解Java多线程编程，涵盖基础概念、线程创建与管理、同步机制、并发工具类、线程池、线程安全集合、实战案例及常见问题解决方案，助你掌握高性能并发编程技巧，应对多线程开发中的挑战。
艾伦~耶格尔
360 0
小白学大数据
|
5月前
|
数据采集 存储 前端开发
Java爬虫性能优化：多线程抓取JSP动态数据实践
Java爬虫性能优化：多线程抓取JSP动态数据实践
小白学大数据
195 0
木叶_之荣
|
算法 Java
Java对象创建、分配、布局、访问小析(HotSpot虚拟机)(一)
本文内容总结自周志明先生所编著的《深入理解Java虚拟机-JVM高级特性与最佳实践》此书的经典不必多说。本节内容是对象的创建.、分配的内容。 对象的创建 java对象的创建有几种方式呢（这里所说的java对象仅限于普通java对象不包含数据和Class对象）？大致有以下四种方式： new关键字。这应该是我们最常见和最常用最简单的创建对象的方式。 使用newInstance方法
木叶_之荣
1965 0
木叶_之荣
|
存储 Java
Java对象创建、分配、布局、访问小析(HotSpot虚拟机)(二)
本文内容总结自周志明先生所编著的《深入理解Java虚拟机-JVM高级特性与最佳实践》此书的经典不必多说。本节内容是对象的内存布局。 在HotSpot虚拟机中，对象在内存中存储的布局可以分为3块区域：对象头、实例数据、对齐填充(Padding)。在32位虚拟机中对象头的大小是8个字节，在64位虚拟机中对象头的大小是16个字节， 如果开启压缩的话，对象头的大小是12个字节。对象头包含两部分的
木叶_之荣
1823 0
木叶_之荣
|
存储 Java
Java对象创建、分配、布局、访问小析(HotSpot虚拟机)(三)
本文内容总结自周志明先生所编著的《深入理解Java虚拟机-JVM高级特性与最佳实践》此书的经典不必多说。本节内容是对象的定位访问。 在java中我们无时无刻不在创建对象，我们创建对象的目的当然是为了使用它了。但是我们怎么才能使用操作创建的对象呢？我们的java程序会通过栈上的reference数据(指向对象的引用)来操作堆上的具体对象。那这个对象的引用是通过什么方式去定位、访问堆中的对象
木叶_之荣
1830 0

热门文章

最新文章

  • 1
    深入分析Java线程中断机制
  • 2
    深入浅出Win32多线程程序设计-【3】线程通信
  • 3
    多线程编程之四 ---线程的同步
  • 4
    UNIX环境高级编程笔记之线程
  • 5
    重新想象 Windows 8 Store Apps (42) - 多线程之线程池: 延迟执行, 周期执行, 在线程池中找一个线程去执行指定的方法
  • 6
    使用线程池的方法（非TPL）-ThreadPool.QueueUserWorkItem
  • 7
    令仔学多线程系列（二）----自定义Queue队列
  • 8
    多线程程序操作共享区域（文件）的一点体会
  • 9
    Java多线程基础-11：工厂模式及代码案例之线程池（一）
  • 10
    Linux下多线程编程简介（五）
  • 1
    Java 设计模式之策略模式：灵活切换算法的艺术
    461
  • 2
    Java 设计模式之观察者模式：构建松耦合的事件响应系统
    367
  • 3
    Java 设计模式之状态模式：让对象的行为随状态优雅变化
    399
  • 4
    java零基础学习者入门课程
    363
  • 5
    Java 设计模式之责任链模式：优雅处理请求的艺术
    413
  • 6
    【Azure Storage Account】Java Code访问Storage Account File Share的上传和下载代码示例
    400
  • 7
    百宝箱开放平台 ✖️ Java SDK
    1348
  • 8
    《深入理解Spring》：现代Java开发的核心框架
    590
  • 9
    用Java语言实现一个自定义的ArrayList类
    158
  • 10
    从混沌到秩序：Java共享内存模型如何通过显式约束驯服并发？
    112

    • 相关课程

    更多
  • Java面试疑难点解析 - 面试技巧及语言基础
  • Java面试疑难点解析 - Java Web开发
  • Java面试疑难点解析 - 系统架构及项目设计
  • Java编程入门
  • Java面向对象编程
  • Java高级编程

    • 相关电子书

    更多
  • Spring Cloud Alibaba - 重新定义 Java Cloud-Native
  • The Reactive Cloud Native Arch
  • 多IO线程优化版
    • 下一篇
    基于JAVA的高校宿舍管理系统的设计与实现(论文+源码)_kaic