#スレッド プールの概要

1. スレッド プールは、スレッドを管理するプールであり、作成を削減できます。スレッドの破棄によりリソースが消費(fèi)されます。

スレッドは実際にはオブジェクトであるため、オブジェクトを作成するには、クラスの読み込みプロセスを経て、オブジェクトを破棄し、GC ガベージを経る必要があります。収集プロセスのすべてにリソースのオーバーヘッドが必要です。

2. 応答速度の向上: タスクが到著したときに、スレッド プールからスレッドを取得する場合に比べ、自分でスレッドを作成する方が確実に遅くなります。使い終わったらスレッドをプールに戻し、再利用の効果を?qū)g現(xiàn)します

(推奨ビデオ:

java ビデオ チュートリアル

)

スレッド プールの実行

メタファーを作成するコア スレッドを會社の正規(guī)従業(yè)員と比較します

非コア スレッドを外注従業(yè)員と比較します

ブロッキング キューはデマンド プールと比較されます

タスクの送信は送信と比較されます要件

正式な実行

public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize,long keepAliveTime,TimeUnit unit,
   BlockingQueue<Runnable> workQueue,
   ThreadFactory threadFactory,
   RejectedExecutionHandler handler)

corePoolSize     核心線程數(shù)
maximumPoolSize  線程池最大線程數(shù)
keepAliveTime    空閑線程存活時(shí)間
TimeUnit         線程空閑存活時(shí)間單位
workQueue        存放任務(wù)的阻塞隊(duì)列
threadFactory    線程工廠
handler          飽和策略

● タスクを送信し、スレッド プール內(nèi)に殘っているコア スレッドの數(shù)がスレッド數(shù) corePoolSize より少ない場合、スレッド プールは、送信されたタスクを処理するためのコア スレッドを作成します。 ## ● スレッド プール內(nèi)のコア スレッドの數(shù)がいっぱいの場合、つまりスレッドの數(shù)が corePoolSize と等しい場合、新しく送信されたタスクはタスク キュー workQueue に置かれ、実行のためにキューに入れられます。

# スレッド プール內(nèi)に殘っているスレッドの數(shù)が corePoolSize と等しく、タスク キュー workQueue もいっぱいの場合、スレッドの數(shù)が MaximumPoolSize に達(dá)しているかどうか、つまりスレッドの最大數(shù)が 0 であるかどうかを判斷します。そうでない場合は、非コアを作成します スレッドは、送信されたタスクを?qū)g行します。

# 現(xiàn)在のスレッド數(shù)がmaximumPoolSizeに達(dá)し、新しいタスクが來ると、拒否ポリシーが直接使用されます。

いくつかの飽和戦略

AbortPolicy         拋出一個(gè)異常，默認(rèn)的
DiscardPolicy       直接丟棄任務(wù)
DiscardOldestPolicy 丟棄隊(duì)列里最老的任務(wù)，將當(dāng)前這個(gè)任務(wù)繼續(xù)提交給線程池
CallerRunsPolicy    交給線程池調(diào)用所在的線程進(jìn)行處理

スレッド プール例外処理

スレッド プール中にスレッド処理タスクが発生するためcall 例外はスレッド プールによってキャッチされる可能性があるため、タスクの実行が認(rèn)識されない可能性があるため、スレッド プールの例外を考慮する必要があります。

方法 1:

@Test
public void test1() throws Exception {
    ExecutorService executorService = Executors.newFixedThreadPool(5);
    for (int i = 0; i < 5; i++) {
        executorService.submit(new Runnable() {
            @Override
            public void run() {
                try {
                    System.out.println("name: " + Thread.currentThread().getName());
                    Object a = null;
                    System.out.println(a.hashCode());
                } catch (Exception e) {
                    System.out.println(e);
                }
            }
        });
    }
}

方法 2:

@Test
public void test2() throws Exception {
    ExecutorService executorService = Executors.newFixedThreadPool(5);
    for (int i = 0; i < 20; i++) {
        Future<?> future = executorService.submit(new Runnable() {
            @Override
            public void run() {
                System.out.println("name: " + Thread.currentThread().getName());
                Object a = null;
                System.out.println(a.hashCode());
            }
        });
        try {
            future.get();
        } catch (Exception e) {
            System.out.println(e);
        }
    }
}

スレッド プール ワーク キュー

● ArrayBlockingQueue

● LinkedBlockingQueue#● SynchronousQueue

#● DelayQueue

#● PriorityBlockingQueue

==ArrayBlockingQueue==

● 特定の配列を初期化します。容量

# 再入可能なロックを使用します。デフォルトでは不公平なロックが使用されます。エンキューとデキューは同じロックを共有します。相互排他

# は制限された設(shè)計(jì)です。容量がいっぱいの場合、要素は使用できません。要素が削除されるまで追加される

# 使用する場合は、連続メモリを開放してください 初期化容量が大きすぎるとリソースの無駄が発生しやすくなります 小さすぎるとリソースの無駄が発生しやすくなります追加に失敗しました。

#==LinkedBlockingQueue==

● リンク リスト データ構(gòu)造を使用します

#● 非連続メモリ空間

## ● 2 つのリエントラント ロックを使用します要素の入口と出口をそれぞれ制御し、Condition を使用してスレッド間のウェイクアップとデキューを行います。 Wait

● 境界あり、デフォルトのコンストラクターの容量は Integer.MAX_VALUE

==SynchronousQueue= =

#● 內(nèi)部容量は 0

● すべての削除操作は挿入操作を待機(jī)する必要があります

##● すべての挿入操作は削除操作を待機(jī)する必要があります

# 要素の場合、挿入スレッドと削除スレッドが存在すると、すぐに挿入スレッドは削除スレッドに渡されます。このコンテナはチャネルに相當(dāng)し、要素は格納されません

● マルチタスク キューでは、これがタスクを処理する最も速い方法です。

#==PriorityBlockingQueue==

#● 無制限の設(shè)計(jì)ですが、実際の容量はシステム リソースに依存します。

## ● 要素を追加し、複數(shù)の場合は優(yōu)先順位を入力します

==DelayQueue==

● ボーダレスデザイン

#● 追加 (put) はブロックせず、ブロックを削除します

● 要素には有効期限があります

● 期限切れの要素のみが取り出されます

一般的に使用されるスレッド プール

● newFixedThreadPool (スレッド數(shù)が固定されたスレッド プール)

● newCachedThreadPool (スレッドをキャッシュできるスレッド プール)

#● newSingleThreadExecutor (シングル スレッド スレッド プール)

#● newScheduledThreadPool (スケジュールされた定期的な実行用のスレッド プール)

== newFixedThreadPool==

public static ExecutorService newFixedThreadPool(int nThreads) {
    return new ThreadPoolExecutor(nThreads, nThreads,
                                  0L, TimeUnit.MILLISECONDS,
                                  new LinkedBlockingQueue<Runnable>());
}

機(jī)能

1. コア スレッドの數(shù)は、スレッドの最大數(shù)と同じです

2.いわゆる非アイドル時(shí)間、つまり keepAliveTime は 0

3 です。ブロッキング キューは無制限のキューです LinkedBlockingQueue

動作メカニズム:

#● タスクの送信

##● スレッド數(shù)がコア スレッドより少ない場合は、タスクを?qū)g行するためのコア スレッドを作成します

● スレッド數(shù)がコア スレッドと等しい場合、タスクを LinkedBlockingQueue ブロッキング キューに追加します

● 如果線程執(zhí)行完任務(wù)，去阻塞隊(duì)列取任務(wù)，繼續(xù)執(zhí)行。

==newCachedThreadPool==

public static ExecutorService newCachedThreadPool() {
    return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                  60L, TimeUnit.SECONDS,
                                  new SynchronousQueue<Runnable>());
}

線程池特點(diǎn)

● 核心線程數(shù)為0

● 最大線程數(shù)為Integer.MAX_VALUE

● 阻塞隊(duì)列是SynchronousQueue

● 非核心線程空閑存活時(shí)間為60秒

工作機(jī)制：

● 提交任務(wù)

● 因?yàn)闆]有核心線程，所以任務(wù)直接加到SynchronousQueue隊(duì)列。

● 判斷是否有空閑線程，如果有，就去取出任務(wù)執(zhí)行。

● 如果沒有空閑線程，就新建一個(gè)線程執(zhí)行。

● 執(zhí)行完任務(wù)的線程，還可以存活60秒，如果在這期間，接到任務(wù)，可以繼續(xù)活下去；否則，被銷毀。

使用場景

用于并發(fā)執(zhí)行大量短期的小任務(wù)。

使用SynchronousQueue作為工作隊(duì)列，工作隊(duì)列本身并不限制待執(zhí)行的任務(wù)的數(shù)量。但此時(shí)需要限定線程池的最大大小為一個(gè)合理的有限值，而不是Integer.MAX_VALUE，否則可能導(dǎo)致線程池中的工作者線程的數(shù)量一直增加到系統(tǒng)資源所無法承受為止。

如果應(yīng)用程序確實(shí)需要比較大的工作隊(duì)列容量，而又想避免無界工作隊(duì)列可能導(dǎo)致的問題，不妨考慮SynchronousQueue。SynchronousQueue實(shí)現(xiàn)上并不使用緩存空間

==newSingleThreadExecutor==

線程池特點(diǎn)

● 核心線程數(shù)為1

● 最大線程數(shù)也為1

● 阻塞隊(duì)列是LinkedBlockingQueue

● keepAliveTime為0

public static ExecutorService newSingleThreadExecutor(ThreadFactory threadFactory) {
    return new FinalizableDelegatedExecutorService
        (new ThreadPoolExecutor(1, 1,
                                0L, TimeUnit.MILLISECONDS,
                                new LinkedBlockingQueue<Runnable>(),
                                threadFactory));
}

工作機(jī)制

● 提交任務(wù)

● 線程池是否有一條線程在，如果沒有，新建線程執(zhí)行任務(wù)

● 如果有，講任務(wù)加到阻塞隊(duì)列

● 當(dāng)前的唯一線程，從隊(duì)列取任務(wù)，執(zhí)行完一個(gè)，再繼續(xù)取，一個(gè)人（一條線程）夜以繼日地干活。

使用場景

適用于串行執(zhí)行任務(wù)的場景，一個(gè)任務(wù)一個(gè)任務(wù)的執(zhí)行

==newScheduledThreadPool==

線程池特點(diǎn)

public ScheduledThreadPoolExecutor(int corePoolSize) {
    super(corePoolSize, Integer.MAX_VALUE, 0, NANOSECONDS,new DelayedWorkQueue());
}

●?最大線程數(shù)為Integer.MAX_VALUE

●?阻塞隊(duì)列是DelayedWorkQueue

●?keepAliveTime為0

●?scheduleAtFixedRate() ：按某種速率周期執(zhí)行

●?scheduleWithFixedDelay()：在某個(gè)延遲后執(zhí)行

工作機(jī)制

●?添加一個(gè)任務(wù)

●?線程池中的線程從 DelayQueue 中取任務(wù)

●?線程從 DelayQueue 中獲取 time 大于等于當(dāng)前時(shí)間的task

●?執(zhí)行完后修改這個(gè) task 的 time 為下次被執(zhí)行的時(shí)間

●?這個(gè) task 放回DelayQueue隊(duì)列中

scheduleWithFixedDelay

●?無論任務(wù)執(zhí)行時(shí)間長短，都是當(dāng)?shù)谝粋€(gè)任務(wù)執(zhí)行完成之后，延遲指定時(shí)間再開始執(zhí)行第二個(gè)任務(wù)

scheduleAtFixedRate

●?在任務(wù)執(zhí)行時(shí)間小于間隔時(shí)間的情況下，程序以起始時(shí)間為準(zhǔn)則，每隔指定時(shí)間執(zhí)行一次，不受任務(wù)執(zhí)行時(shí)間影響

●?當(dāng)執(zhí)行任務(wù)時(shí)間大于間隔時(shí)間，此方法不會重新開啟一個(gè)新的任務(wù)進(jìn)行執(zhí)行，而是等待原有任務(wù)執(zhí)行完成，馬上開啟下一個(gè)任務(wù)進(jìn)行執(zhí)行。此時(shí)，執(zhí)行間隔時(shí)間已經(jīng)被打亂

本文來自php中文網(wǎng)，java教程欄目，歡迎學(xué)習(xí)！

以上がJavaスレッドプールの詳しい説明の詳細(xì)內(nèi)容です。詳細(xì)については、PHP 中國語 Web サイトの他の関連記事を參照してください。