2. 程式人生 > >線程池基礎一

線程池基礎一

阿新 • • 發佈：2017-10-09
程序 bsp exce static seconds code interrupt edt 進行

技術分享

我們來看下面程序的代碼：經典的生產者消費者來實現

package com.bjsxt.height.design016;

public final class Data {

    private String id;
    private String name;
    
    public Data(String id, String name){
        this.id = id;
        this.name = name;
    }
    
    public String getId() {
        return id;
    }

    
 
public void setId(String id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    @Override
    public String toString(){
        return "{id: " + id + ", name: " + name + "}";
    }
    
}
 

package com.bjsxt.height.design016;

import java.util.Random;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;

public class Provider implements Runnable{
    
    //共享緩存區
    private BlockingQueue<Data> queue;
    
 
//多線程間是否啟動變量，有強制從主內存中刷新的功能。即時返回線程的狀態
    private volatile boolean isRunning = true;
    //id生成器
    private static AtomicInteger count = new AtomicInteger();
    //隨機對象
    private static Random r = new Random(); 
    
    public Provider(BlockingQueue queue){
        this.queue = queue;
    }

    @Override
    public void run() {
        while(isRunning){
            try {
                //隨機休眠0 - 1000 毫秒 表示獲取數據(產生數據的耗時) 
                Thread.sleep(r.nextInt(1000));
                //獲取的數據進行累計...
                int id = count.incrementAndGet();
                //比如通過一個getData方法獲取了
                Data data = new Data(Integer.toString(id), "數據" + id);
                System.out.println("當前線程:" + Thread.currentThread().getName() + ", 獲取了數據，id為:" + id + ", 進行裝載到公共緩沖區中...");
                if(!this.queue.offer(data, 2, TimeUnit.SECONDS)){
                    System.out.println("提交緩沖區數據失敗....");
                    //do something... 比如重新提交
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
    
    public void stop(){
        this.isRunning = false;
    }
    
}

package com.bjsxt.height.design016;

import java.util.Random;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.TimeUnit;

public class Consumer implements Runnable{

    private BlockingQueue<Data> queue;
    
    public Consumer(BlockingQueue queue){
        this.queue = queue;
    }
    
    //隨機對象
    private static Random r = new Random(); 

    @Override
    public void run() {
        while(true){
            try {
                //獲取數據
                Data data = this.queue.take();
                //進行數據處理。休眠0 - 1000毫秒模擬耗時
                Thread.sleep(r.nextInt(1000));
                System.out.println("當前消費線程：" + Thread.currentThread().getName() + "， 消費成功，消費數據為id: " + data.getId());
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

package com.bjsxt.height.design016;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.LinkedBlockingQueue;

public class Main {

    public static void main(String[] args) throws Exception {
        //內存緩沖區
        BlockingQueue<Data> queue = new LinkedBlockingQueue<Data>(10);
        //生產者
        Provider p1 = new Provider(queue);
        
        Provider p2 = new Provider(queue);
        Provider p3 = new Provider(queue);
        //消費者
        Consumer c1 = new Consumer(queue);
        Consumer c2 = new Consumer(queue);
        Consumer c3 = new Consumer(queue);
        //創建線程池運行,這是一個緩存的線程池，可以創建無窮大的線程，沒有任務的時候不創建線程。空閑線程存活時間為60s（默認值）

        ExecutorService cachePool = Executors.newCachedThreadPool();
        cachePool.execute(p1);
        cachePool.execute(p2);
        cachePool.execute(p3);
        cachePool.execute(c1);
        cachePool.execute(c2);
        cachePool.execute(c3);

        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        p1.stop();
        p2.stop();
        p3.stop();
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }        
//        cachePool.shutdown(); 
//        cachePool.shutdownNow();
        

    }
    
}

程序的運行結果是：

當前線程:pool-1-thread-2, 獲取了數據，id為:1, 進行裝載到公共緩沖區中...
當前線程:pool-1-thread-1, 獲取了數據，id為:2, 進行裝載到公共緩沖區中...
當前線程:pool-1-thread-3, 獲取了數據，id為:3, 進行裝載到公共緩沖區中...
當前線程:pool-1-thread-2, 獲取了數據，id為:4, 進行裝載到公共緩沖區中...
當前消費線程：pool-1-thread-6， 消費成功，消費數據為id: 3
當前消費線程：pool-1-thread-4， 消費成功，消費數據為id: 1
當前線程:pool-1-thread-3, 獲取了數據，id為:5, 進行裝載到公共緩沖區中...
當前線程:pool-1-thread-3, 獲取了數據，id為:6, 進行裝載到公共緩沖區中...
當前線程:pool-1-thread-1, 獲取了數據，id為:7, 進行裝載到公共緩沖區中...
當前消費線程：pool-1-thread-4， 消費成功，消費數據為id: 5
當前消費線程：pool-1-thread-5， 消費成功，消費數據為id: 2
當前線程:pool-1-thread-2, 獲取了數據，id為:8, 進行裝載到公共緩沖區中...
當前消費線程：pool-1-thread-6， 消費成功，消費數據為id: 4
當前線程:pool-1-thread-3, 獲取了數據，id為:9, 進行裝載到公共緩沖區中...
當前消費線程：pool-1-thread-5， 消費成功，消費數據為id: 7
當前線程:pool-1-thread-3, 獲取了數據，id為:10, 進行裝載到公共緩沖區中...
當前消費線程：pool-1-thread-6， 消費成功，消費數據為id: 8
當前線程:pool-1-thread-1, 獲取了數據，id為:11, 進行裝載到公共緩沖區中...
當前線程:pool-1-thread-1, 獲取了數據，id為:12, 進行裝載到公共緩沖區中...
當前線程:pool-1-thread-2, 獲取了數據，id為:13, 進行裝載到公共緩沖區中...
當前消費線程：pool-1-thread-4， 消費成功，消費數據為id: 6
當前線程:pool-1-thread-3, 獲取了數據，id為:14, 進行裝載到公共緩沖區中...
當前消費線程：pool-1-thread-5， 消費成功，消費數據為id: 9
當前線程:pool-1-thread-2, 獲取了數據，id為:15, 進行裝載到公共緩沖區中...
當前線程:pool-1-thread-1, 獲取了數據，id為:16, 進行裝載到公共緩沖區中...
當前消費線程：pool-1-thread-5， 消費成功，消費數據為id: 12
當前線程:pool-1-thread-3, 獲取了數據，id為:17, 進行裝載到公共緩沖區中...
當前消費線程：pool-1-thread-6， 消費成功，消費數據為id: 10
當前線程:pool-1-thread-2, 獲取了數據，id為:18, 進行裝載到公共緩沖區中...
當前消費線程：pool-1-thread-4， 消費成功，消費數據為id: 11
當前線程:pool-1-thread-1, 獲取了數據，id為:19, 進行裝載到公共緩沖區中...
當前消費線程：pool-1-thread-5， 消費成功，消費數據為id: 13
當前消費線程：pool-1-thread-5， 消費成功，消費數據為id: 16
當前消費線程：pool-1-thread-4， 消費成功，消費數據為id: 15
當前線程:pool-1-thread-3, 獲取了數據，id為:20, 進行裝載到公共緩沖區中...
當前消費線程：pool-1-thread-5， 消費成功，消費數據為id: 17
當前消費線程：pool-1-thread-6， 消費成功，消費數據為id: 14
當前消費線程：pool-1-thread-4， 消費成功，消費數據為id: 18
當前消費線程：pool-1-thread-5， 消費成功，消費數據為id: 19
當前消費線程：pool-1-thread-6， 消費成功，消費數據為id: 20

相當的經典

線程池基礎一

相關推薦

線程池基礎一

程序 bsp exce static seconds code interrupt edt 進行 我們來看下面程序的代碼：經典的生產者消費者來實現 package com.bjsxt.height.design016; public final class Da

java並發學習--線程池（一）

第一個 down holding scheduled class 缺點 有關 maximum 設計 關於java中的線程池，我一開始覺得就是為了避免頻繁的創建和銷毀線程吧，先創建一定量的線程，然後再進行復用。但是要具體說一下如何做到的，自己又說不出一個一二三來了，這大概就是

java面試總躲不過的並發（一）： 線程池ThreadPoolExecutor基礎梳理

進入 dot keepaliv apt 排序。 定位問題 代碼 微秒 image 本文核心：線程池ThreadPoolExecutor基礎梳理 一.實現多線程的方式 1.繼承Thread類，重寫其run方法 2.實現Runnable接口，實現run方法 3.實

JDFS:一款分布式文件管理實用程序第一篇(線程池、epoll、上傳、下載)

cpu nload tree 程序 fun 是的 發的 fop let 一 前言 　　截止目前，筆者在博客園上面已經發表了3篇關於網絡下載的文章，這三篇博客實現了基於socket的http多線程遠程斷點下載實用程序。筆者打算在此基礎上開發出一款分布式文件管理實用程序，截止目

異步線程池的實現（一）-------具體實現方法

fun format 測試 路徑 線程池。 用戶體驗 deb tar clas 本篇是這個內容的第一篇，主要是寫:遇到的問題，和自己摸索實現的方法。後面還會有一篇是總結性地寫線程池的相關內容（偏理論的）。 一、背景介紹 朋友的項目開發到一定程度之後，又遇到

Java基礎之－ExecutorService(線程池)

color cor ack 基礎 and 運算 margin ast 繪制 今天看的源碼是線程池的部分，記錄下，源碼看的jdk8的。 主要是講述下，創建線程池的過程，以及繪制的原理圖片。 從線程池的execute代碼開始入手 【源碼一】 java.util.co

多線程編程學習一(Java多線程的基礎)

while except 無法 計數器 oid 共享數據 創建 ble src 一、進程和線程的概念 進程：一次程序的執行稱為一個進程，每個 進程有獨立的代碼和數據空間，進程間切換的開銷比較大，一個進程包含1—n個線程。進程是資源分享的最小單位。 線程：同一

JAVA線程池 之 Executors （一）

i++ static 順序 nta executors 情況下 線程的生命周期 有一個 ping 一、背景 　　線程屬於系統稀缺資源，在使用線程時，如果無限制創建線程，達到CPU高負荷時，會導致系統運行緩慢，更有甚者直接宕機。 在這樣的基礎上我們希望在使用線程時，竟可能使系

python---基礎知識回顧（十）進程和線程（自定義線程池，上下文管理器和協程的使用）

elf () self. 數據類型 大小 get 基礎數據類型 __init__ 進行 前戲： 在進行自定義線程池前，先了解下Queue隊列 隊列中可以存放基礎數據類型，也可以存放類，對象等特殊數據類型 from queue import Queue class T:

JAVA線程池原理詳解一

for lar finall r.java worker IT 流程 unlock 都是 線程池的優點 1、線程是稀缺資源，使用線程池可以減少創建和銷毀線程的次數，每個工作線程都可以重復使用。 2、可以根據系統的承受能力，調整線程池中工作線程的數量，防止因為消耗過多內存導致

記錄一次線程池的在項目中的實際應用，講解一下線程池的配置和參數理解。

div pro 繼續 bstr warn fin autowire string ping 前言：最近項目中與融360項目中接口對接，有反饋接口（也就是我們接收到請求，需要立即響應，並且還要有一個接口推送給他們其他計算結果），推送過程耗時、或者說兩個接口不能是同時返回，有先

線程池的基礎與操作

五個 建議 err key tar tac cor pool rdo 一、概念 使用ThreadPoolExecutor類：包含了五個參數int corePoolSize(線程池的基本大小）,int maximumPoolSize（最大線程池容量）,long keepAli

手寫線程池 (一)

手寫 http oid pre encode map auth 任務 容器 前言準備 1.jdk線程池的使用：https://www.cnblogs.com/jtfr/p/10187419.html 2.線程池核心：線程的復用。 　　運行的線程是線程池的核心，被添加的

mysql線程池的實現原理淺析

new one lose clear pre turn logs color 否則 今天抽空主要看了一下mysql線程池（cached threads）的實現原理，總體並不那麽復雜，也學到了一些設計原理，值得記錄一下。為了簡化代碼，讓思路更清晰，我刪去了不少錯誤處理，線程同

【轉載】5天不再懼怕多線程——第五天 線程池

執行 targe 空閑 timer max als htm port 電腦 說到多線程，不可不說線程池，C#中關於池的概念很多，今天來整理下ThreadPool的使用。 是的，如果你很懶，如果你的執行任務比較短，如果你不想對線程做更精細的控制，那麽把這些繁瑣的東西

線程池參數詳解

線程池參數 線程池 參數 java JDK1.5中引入了強大的concurrent包，其中最常用的莫過了線程池的實現ThreadPoolExecutor，它給我們帶來了極大的方便，但同時，對於該線程池不恰當的設置也可能使其效率並不能達到預期的效果，甚至僅相當於或低於單線程的效率。ThreadP

java和spring 線程池總結

一段 getname span 只有一個 [] 觸發 sts time execute 1. spring 的線程池 ThreadPoolTaskExecutor @Configuration public class ThreadPoolConfig {

nginx源碼分析——線程池

memory args 結構體 功能 報錯 threads 退出 endif efault 源碼： nginx 1.13.0-release 一、前言 nginx是采用多進程模型，master和worker之間主要通過pipe管道的方式進行通信，多進程的優勢就

c#自己實現線程池功能(二)

mod 線程池 sharp ise except mar 函數 rac 試圖 介紹 在上一篇c#自己實現線程池功能(一)中，我們基本實現了一個能夠執行的程序。而不能真正的稱作線程池。因為是上篇中的代碼有個致命的bug那就是沒有任務是並非等待，而是瘋狂的進行while循環

Java 線程池的原理與實現

控制 try 所在 使用 urn str waiting media .info 這幾天主要是狂看源程序，在彌補了一些曾經知識空白的同一時候，也學會了不少新的知識（比方 NIO）。或者稱為新技術吧。 線程池就是當中之中的一個，一提到線程。我們會想到曾經《操作系統》的