欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

線程池ThreadPoolExecutor使用簡(jiǎn)介與方法實(shí)例

 更新時(shí)間:2019年03月12日 09:39:19   作者:小飛俠-2  
今天小編就為大家分享一篇關(guān)于線程池ThreadPoolExecutor使用簡(jiǎn)介與方法實(shí)例,小編覺得內(nèi)容挺不錯(cuò)的,現(xiàn)在分享給大家,具有很好的參考價(jià)值,需要的朋友一起跟隨小編來看看吧

一、簡(jiǎn)介

線程池類為 java.util.concurrent.ThreadPoolExecutor,常用構(gòu)造方法為:

ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, 
long keepAliveTime, TimeUnit unit, 
BlockingQueue workQueue, 
RejectedExecutionHandler handler) 
  • corePoolSize: 線程池維護(hù)線程的最少數(shù)量
  • maximumPoolSize:線程池維護(hù)線程的最大數(shù)量
  • keepAliveTime: 線程池維護(hù)線程所允許的空閑時(shí)間
  • unit: 線程池維護(hù)線程所允許的空閑時(shí)間的單位
  • workQueue: 線程池所使用的緩沖隊(duì)列
  • handler: 線程池對(duì)拒絕任務(wù)的處理策略

一個(gè)任務(wù)通過 execute(Runnable)方法被添加到線程池,任務(wù)就是一個(gè) Runnable類型的對(duì)象,任務(wù)的執(zhí)行方法就是 Runnable類型對(duì)象的run()方法。

當(dāng)一個(gè)任務(wù)通過execute(Runnable)方法欲添加到線程池時(shí):

  • 如果此時(shí)線程池中的數(shù)量小于corePoolSize,即使線程池中的線程都處于空閑狀態(tài),也要?jiǎng)?chuàng)建新的線程來處理被添加的任務(wù)。
  • 如果此時(shí)線程池中的數(shù)量等于 corePoolSize,但是緩沖隊(duì)列 workQueue未滿,那么任務(wù)被放入緩沖隊(duì)列。
  • 如果此時(shí)線程池中的數(shù)量大于corePoolSize,緩沖隊(duì)列workQueue滿,并且線程池中的數(shù)量小于maximumPoolSize,建新的線程來處理被添加的任務(wù)。
  • 如果此時(shí)線程池中的數(shù)量大于corePoolSize,緩沖隊(duì)列workQueue滿,并且線程池中的數(shù)量等于maximumPoolSize,那么通過 handler所指定的策略來處理此任務(wù)。

也就是:處理任務(wù)的優(yōu)先級(jí)為:

核心線程corePoolSize、任務(wù)隊(duì)列workQueue、最大線程maximumPoolSize,如果三者都滿了,使用handler處理被拒絕的任務(wù)。

當(dāng)線程池中的線程數(shù)量大于 corePoolSize時(shí),如果某線程空閑時(shí)間超過keepAliveTime,線程將被終止。這樣,線程池可以動(dòng)態(tài)的調(diào)整池中的線程數(shù)。

unit可選的參數(shù)為java.util.concurrent.TimeUnit中的幾個(gè)靜態(tài)屬性:

NANOSECONDS、MICROSECONDS、MILLISECONDS、SECONDS。

workQueue我常用的是:java.util.concurrent.ArrayBlockingQueue

handler有四個(gè)選擇:

  • ThreadPoolExecutor.AbortPolicy() 拋出java.util.concurrent.RejectedExecutionException異常
  • ThreadPoolExecutor.CallerRunsPolicy() 重試添加當(dāng)前的任務(wù),他會(huì)自動(dòng)重復(fù)調(diào)用execute()方法
  • ThreadPoolExecutor.DiscardOldestPolicy() 拋棄舊的任務(wù)
  • ThreadPoolExecutor.DiscardPolicy() 拋棄當(dāng)前的任務(wù)

二、一般用法舉例

package demo;
import java.io.Serializable;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class TestThreadPool2
{
  private static int produceTaskSleepTime = 2;
  private static int produceTaskMaxNumber = 10;
  public static void main(String[] args)
  {
    // 構(gòu)造一個(gè)線程池
    ThreadPoolExecutor threadPool = new ThreadPoolExecutor(2, 4, 3, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(3),
        new ThreadPoolExecutor.DiscardOldestPolicy());
    for (int i = 1; i <= produceTaskMaxNumber; i++)
    {
      try
      {
        // 產(chǎn)生一個(gè)任務(wù),并將其加入到線程池
        String task = "task@ " + i;
        System.out.println("put " + task);
        threadPool.execute(new ThreadPoolTask(task));
        // 便于觀察,等待一段時(shí)間
        Thread.sleep(produceTaskSleepTime);
      }
      catch (Exception e)
      {
        e.printStackTrace();
      }
    }
  }
}
/**
 * 線程池執(zhí)行的任務(wù)
 */
class ThreadPoolTask implements Runnable, Serializable
{
  private static final long serialVersionUID = 0;
  private static int consumeTaskSleepTime = 2000;
  // 保存任務(wù)所需要的數(shù)據(jù)
  private Object threadPoolTaskData;
  ThreadPoolTask(Object tasks)
  {
    this.threadPoolTaskData = tasks;
  }
  public void run()
  {
    // 處理一個(gè)任務(wù),這里的處理方式太簡(jiǎn)單了,僅僅是一個(gè)打印語(yǔ)句
    System.out.println(Thread.currentThread().getName());
    System.out.println("start .." + threadPoolTaskData);
    try
    {
      // //便于觀察,等待一段時(shí)間
      Thread.sleep(consumeTaskSleepTime);
    }
    catch (Exception e)
    {
      e.printStackTrace();
    }
    threadPoolTaskData = null;
  }
  public Object getTask()
  {
    return this.threadPoolTaskData;
  }
}

說明:

1、在這段程序中,一個(gè)任務(wù)就是一個(gè)Runnable類型的對(duì)象,也就是一個(gè)ThreadPoolTask類型的對(duì)象。

2、一般來說任務(wù)除了處理方式外,還需要處理的數(shù)據(jù),處理的數(shù)據(jù)通過構(gòu)造方法傳給任務(wù)。

3、在這段程序中,main()方法相當(dāng)于一個(gè)殘忍的領(lǐng)導(dǎo),他派發(fā)出許多任務(wù),丟給一個(gè)叫 threadPool的任勞任怨的小組來做。

這個(gè)小組里面隊(duì)員至少有兩個(gè),如果他們兩個(gè)忙不過來,任務(wù)就被放到任務(wù)列表里面。

如果積壓的任務(wù)過多,多到任務(wù)列表都裝不下(超過3個(gè))的時(shí)候,就雇傭新的隊(duì)員來幫忙。但是基于成本的考慮,不能雇傭太多的隊(duì)員,至多只能雇傭 4個(gè)。

如果四個(gè)隊(duì)員都在忙時(shí),再有新的任務(wù),這個(gè)小組就處理不了了,任務(wù)就會(huì)被通過一種策略來處理,我們的處理方式是不停的派發(fā),直到接受這個(gè)任務(wù)為止(更殘忍!呵呵)。

因?yàn)殛?duì)員工作是需要成本的,如果工作很閑,閑到 3SECONDS都沒有新的任務(wù)了,那么有的隊(duì)員就會(huì)被解雇了,但是,為了小組的正常運(yùn)轉(zhuǎn),即使工作再閑,小組的隊(duì)員也不能少于兩個(gè)。

4、通過調(diào)整 produceTaskSleepTime和 consumeTaskSleepTime的大小來實(shí)現(xiàn)對(duì)派發(fā)任務(wù)和處理任務(wù)的速度的控制,改變這兩個(gè)值就可以觀察不同速率下程序的工作情況。

5、通過調(diào)整4中所指的數(shù)據(jù),再加上調(diào)整任務(wù)丟棄策略,換上其他三種策略,就可以看出不同策略下的不同處理方式。

6、對(duì)于其他的使用方法,參看jdk的幫助,很容易理解和使用。

另一個(gè)例子:

package demo;
import java.util.Queue;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class ThreadPoolExecutorTest
{
  private static int queueDeep = 4;
  public void createThreadPool()
  {
    /* 
     * 創(chuàng)建線程池,最小線程數(shù)為2,最大線程數(shù)為4,線程池維護(hù)線程的空閑時(shí)間為3秒, 
     * 使用隊(duì)列深度為4的有界隊(duì)列,如果執(zhí)行程序尚未關(guān)閉,則位于工作隊(duì)列頭部的任務(wù)將被刪除, 
     * 然后重試執(zhí)行程序(如果再次失敗,則重復(fù)此過程),里面已經(jīng)根據(jù)隊(duì)列深度對(duì)任務(wù)加載進(jìn)行了控制。 
     */ 
    ThreadPoolExecutor tpe = new ThreadPoolExecutor(2, 4, 3, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(queueDeep),
        new ThreadPoolExecutor.DiscardOldestPolicy());
    // 向線程池中添加 10 個(gè)任務(wù)
    for (int i = 0; i < 10; i++)
    {
      try
      {
        Thread.sleep(1);
      }
      catch (InterruptedException e)
      {
        e.printStackTrace();
      }
      while (getQueueSize(tpe.getQueue()) >= queueDeep)
      {
        System.out.println("隊(duì)列已滿,等3秒再添加任務(wù)");
        try
        {
          Thread.sleep(3000);
        }
        catch (InterruptedException e)
        {
          e.printStackTrace();
        }
      }
      TaskThreadPool ttp = new TaskThreadPool(i);
      System.out.println("put i:" + i);
      tpe.execute(ttp);
    }
    tpe.shutdown();
  }
  private synchronized int getQueueSize(Queue queue)
  {
    return queue.size();
  }
  public static void main(String[] args)
  {
    ThreadPoolExecutorTest test = new ThreadPoolExecutorTest();
    test.createThreadPool();
  }
  class TaskThreadPool implements Runnable
  {
    private int index;
    public TaskThreadPool(int index)
    {
      this.index = index;
    }
    public void run()
    {
      System.out.println(Thread.currentThread() + " index:" + index);
      try
      {
        Thread.sleep(3000);
      }
      catch (InterruptedException e)
      {
        e.printStackTrace();
      }
    }
  }
}

總結(jié)

以上就是這篇文章的全部?jī)?nèi)容了,希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,謝謝大家對(duì)腳本之家的支持。如果你想了解更多相關(guān)內(nèi)容請(qǐng)查看下面相關(guān)鏈接

相關(guān)文章

  • 雙token實(shí)現(xiàn)token超時(shí)策略示例

    雙token實(shí)現(xiàn)token超時(shí)策略示例

    用于restful的app應(yīng)用無狀態(tài)無sesion登錄示例,需要的朋友可以參考下
    2014-02-02
  • 給JavaBean賦默認(rèn)值并且轉(zhuǎn)Json字符串的實(shí)例

    給JavaBean賦默認(rèn)值并且轉(zhuǎn)Json字符串的實(shí)例

    這篇文章主要介紹了給JavaBean賦默認(rèn)值并且轉(zhuǎn)Json字符串的實(shí)例,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2022-03-03
  • Java設(shè)計(jì)模式之適配器模式的實(shí)現(xiàn)

    Java設(shè)計(jì)模式之適配器模式的實(shí)現(xiàn)

    這篇文章主要介紹了Java設(shè)計(jì)模式之適配器模式的實(shí)現(xiàn),適配器模式(Adapter Pattern)是作為兩個(gè)不兼容的接口之間的橋梁,這種類型的設(shè)計(jì)模式屬于結(jié)構(gòu)型模式,它結(jié)合了兩個(gè)獨(dú)立接口的功能,需要的朋友可以參考下
    2023-11-11
  • Spring Bean的線程安全問題

    Spring Bean的線程安全問題

    Spring容器中的Bean是否線程安全,本文主要介紹了Spring Bean的線程安全問題,文中通過示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2022-06-06
  • Spring Boot整合Spring Security的示例代碼

    Spring Boot整合Spring Security的示例代碼

    這篇文章主要介紹了Spring Boot整合Spring Security的示例代碼,小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧
    2018-04-04
  • 詳解SpringMVC的兩種實(shí)現(xiàn)方式

    詳解SpringMVC的兩種實(shí)現(xiàn)方式

    這篇文章主要介紹了SpringMVC的兩種實(shí)現(xiàn)方式,方式一是通過實(shí)現(xiàn)Controller接口,方式二是使用注解開發(fā),本文結(jié)合示例代碼給大家介紹的非常詳細(xì),需要的朋友可以參考下
    2022-10-10
  • spring data jpa 查詢自定義字段,轉(zhuǎn)換為自定義實(shí)體方式

    spring data jpa 查詢自定義字段,轉(zhuǎn)換為自定義實(shí)體方式

    這篇文章主要介紹了spring data jpa 查詢自定義字段,轉(zhuǎn)換為自定義實(shí)體方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2021-06-06
  • SpringBoot詳細(xì)列舉常用注解的說明

    SpringBoot詳細(xì)列舉常用注解的說明

    在開發(fā)SpringBoot程序的過程中,有可能與其他業(yè)務(wù)系統(tǒng)進(jìn)行對(duì)接開發(fā),獲取封裝公共的API接口等等,下面這篇文章主要給大家介紹了關(guān)于SpringBoot常見的注解的相關(guān)資料,需要的朋友可以參考下
    2022-06-06
  • Java list foreach修改元素方式

    Java list foreach修改元素方式

    這篇文章主要介紹了Java list foreach修改元素方式,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2023-11-11
  • Java超詳細(xì)教你寫一個(gè)網(wǎng)絡(luò)購(gòu)書系統(tǒng)案例

    Java超詳細(xì)教你寫一個(gè)網(wǎng)絡(luò)購(gòu)書系統(tǒng)案例

    這篇文章主要介紹了怎么用Java來寫一個(gè)購(gòu)書系統(tǒng),購(gòu)買書籍主要需要每本書的編號(hào)、書名、單價(jià)、庫(kù)存屬性,能夠讓客戶通過編號(hào)來選書,感興趣的朋友跟隨文章往下看看吧
    2022-03-03

最新評(píng)論