当前位置:主页 > java教程 > java自定义线程池的原理简介

浅析java自定义线程池原理

发布:2020-03-02 11:47:48 68


我们帮大家精选了Java相关的编程文章,网友龙家美根据主题投稿了本篇教程内容,涉及到java、线程池、java自定义线程池的原理简介相关内容,已被118网友关注,相关难点技巧可以阅读下方的电子资料。

java自定义线程池的原理简介

线程池的相关概念就不在这里说明了,百度一下有很多,这里简单表述一下如何实现一个自定义的线程池就行线程管理,我们如果要实现一个线程池对线程的管理,那么需要实现一下几点的思路:

1.如何管理线程

2.如何定义工作线程以及工作线程如何持续的保持运行状态

3.如何定义线程池大小及队列大小

4.如何提供接口给调用者使用

5.如何关闭线程池中的线程

接下来我们就一一的实现这几个问题。

1.我们需要定义一个队列来来管理线程,这里使用了LinkedBlockingQueue

// 1.定义一个存储线程队列 
private LinkedBlockingQueue<Runnable> queue; 

2.因为是一个简单的测试,所以我们可以先定义一个内部类来实现工作线程

// 2.定义工作线程进行线程的执行 
  class Worker extends Thread {  
    private SelfThreadPoolExecutor threadPoolExecutor; 
 
    public Worker(SelfThreadPoolExecutor poolExecutor) { 
      this.threadPoolExecutor = poolExecutor; 
    }  
    @Override 
    public void run() { 
      Runnable task; 
      while (threadPoolExecutor.receiveTask || threadPoolExecutor.queue.size() > 0) { 
        try { 
          // 有线程则取出来,否则等待 
          System.out.println("准备消费线程"); 
          task = threadPoolExecutor.queue.take(); 
          if (task != null) { 
            task.run(); 
            System.out.println("消费线程"); 
          } 
        } catch (InterruptedException e) { 
          e.printStackTrace(); 
        } 
      } 
    } 
  } 

SelfThreadPoolExecutor是外部定义的整体类名

3.使用有参的构造方法进行线程池大小的管理

// 3.存放工作线程的集合 
  private List<Worker> workerList;  
  // 4.线程池初始化 
  public SelfThreadPoolExecutor(int coreSize, int queueSize) { 
    if (coreSize <= 0 || queueSize <= 0) { 
      throw new IllegalArgumentException("参数不正确"); 
    } 
    this.queue = new LinkedBlockingQueue<>(queueSize); 
    // 线程安全的集合 
    this.workerList = Collections.synchronizedList(new ArrayList<>()); 
    for (int i = 0; i < coreSize; i++) { 
      Worker worker = new Worker(this); 
      worker.start(); 
      workerList.add(worker); 
    } 
  } 

4.定义阻塞和非阻塞的方式提供对应的接口

// 5.非阻塞的方法接口 
  public boolean offer(Runnable task) { 
    if (receiveTask) { 
      return queue.offer(task); 
    } else { 
      return false; 
    } 
  } 
  // 6.阻塞的方法接口 
  public void put(Runnable task) { 
    try { 
      if (receiveTask) { 
        queue.put(task); 
      } 
    } catch (InterruptedException e) { 
      e.printStackTrace(); 
    } 
  } 

6.进行线程池的关闭

// 7.线程池的关闭 
  private boolean receiveTask = true;  
  public void shutdown() { 
    // 7.1.队列不再接收线程 
    receiveTask = false; 
    // 7.2.关闭处于wait或block的线程 
    for (Thread thread : workerList) { 
      if (Thread.State.BLOCKED.equals(thread.getState()) 
      || Thread.State.WAITING.equals(thread.getState()) 
      || Thread.State.TIMED_WAITING.equals(thread.getState())){ 
        thread.interrupt(); 
      } 
    } 
  } 

我们测试的方法如下:

public static void main(String [] args){ 
    SelfThreadPoolExecutor selfThreadPoolExecutor = new SelfThreadPoolExecutor(5,10); 
    for(int i = 0;i < 20;i++){ 
      Runnable task = () ->{ 
        System.out.println("开启线程"); 
      }; 
      selfThreadPoolExecutor.put(task); 
    } 
    selfThreadPoolExecutor.shutdown(); 
  } 

运行结果是:

准备消费线程 
准备消费线程 
准备消费线程 
准备消费线程 
准备消费线程 
开启线程 
消费线程 
准备消费线程 
开启线程 
消费线程 
准备消费线程 
开启线程 
消费线程 
准备消费线程 
。。。。。。 

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持码农之家。


参考资料

相关文章

  • 实例详解Java日志相关技术_动力节点Java学院整理

    发布:2020-02-05

    这篇文章主要介绍了Java日志相关技术_动力节点Java学院整理的相关资料,需要的朋友可以参考下


  • Java设计模式中的七大原则详细讲解

    发布:2023-03-31

    本篇文章主要对Java中的设计模式如,创建型模式、结构型模式和行为型模式以及7大原则进行了归纳整理,需要的朋友可以参考下,希望能给你带来帮助


  • Java经典面试题最全汇总208道(二)

    发布:2023-03-13

    这篇文章主要介绍了Java经典面试题最全汇总208道(二),本文章内容详细,该模块分为了六个部分,本次为第二部分,需要的朋友可以参考下<BR>


  • java中两种树形菜单结构的转换代码实例

    发布:2019-06-05

    这篇文章主要介绍了java编程两种树形菜单结构的转换代码,首先介绍了两种树形菜单结构的代码,然后展示了转换器实例代码,最后分享了相关实例及结果演示,具有一定借鉴价值,需要的朋


  • java实现翻转单词顺序列

    发布:2022-10-20

    为网友们分享了关于java的教程,这篇文章主要为大家详细介绍了java实现翻转单词顺序列,具有一定的参考价值,感兴趣的小伙伴们可以参考一下


  • Java设计模式之原型模式Prototype

    发布:2020-01-27

    这篇文章主要为大家详细介绍了Java设计模式之Prototype原型模式的相关资料,具有一定的参考价值,感兴趣的小伙伴们可以参考一下


  • Java中documentHelper解析xml获取想要的数据

    发布:2023-04-19

    本文主要介绍了Java中documentHelper解析xml获取想要的数据,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧


  • Java Set接口及常用实现类总结

    发布:2023-03-02

    Collection的另一个子接口就是Set,他并没有我们List常用,并且自身也没有一些额外的方法,全是继承自Collection中的,因此我们还是简单总结一下,包括他的常用实现类HashSet、LinkedHashSet、TreeSet的总结


网友讨论