Springboot 独自のスレッドプールを実装する方法-＆＃＆チュートリアル-php.cn

1: ThreadPoolTaskExecuto

1 ThreadPoolTaskExecutor スレッドプール:

ThreadPoolTaskExecutor は、Java 独自のスレッドプール ThreadPoolExecutor に基づく Spring の二次カプセル化です。主な目的は、Spring フレームワークシステムでより便利にすることです。スレッドプールは Spring で使用されます。これは Spring のデフォルトのスレッドプールです。

2 ThreadPoolTaskExecutor を使用して、ioc
構成ファイルフォームに Bean を注入します。Spring は自動的に

## 默认线程池配置,ThreadPoolTaskExecutor # 核心线程数 spring.task.execution.pool.core-size=8 # 最大线程数 spring.task.execution.pool.max-size=16 # 空闲线程存活时间 spring.task.execution.pool.keep-alive=60s # 是否允许核心线程超时 spring.task.execution.pool.allow-core-thread-timeout=true # 线程队列数量 spring.task.execution.pool.queue-capacity=100 # 线程关闭等待 spring.task.execution.shutdown.await-termination=false spring.task.execution.shutdown.await-termination-period= # 线程名称前缀 spring.task.execution.thread-name-prefix=demo_Thread

ログイン後にコピー

Configuration フォームを構成します。 :

import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.Executor; import java.util.concurrent.ScheduledFuture; //@Configuration public class ThreadConfig { @Value("${task.maxPoolSize}") private int maxPoolSize; //todo 其他的相关配置都可以通过配置文件中注入 @Bean("ThreadPoolTaskExecutor") public Executor myAsync() { final ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); executor.setMaxPoolSize(maxPoolSize); //todo 其他参数设置 //初始化 executor.initialize(); return executor; } }

ログイン後にコピー

3 スレッド作成後、ioc

4 からすべてのスレッドプールを取得します。スレッドプール処理プロセス:

(1) コアスレッドプールがいっぱいかどうかを確認します。そうでない場合は、タスクを実行するためのスレッドを作成し、コアスレッド数がいっぱいの場合は、タスクキューがいっぱいかどうかを確認し、そうでない場合は、タスクキューにスレッドを格納します。タスクキューがいっぱいの場合は、最大スレッド数を確認します。そうでない場合は、タスクを実行するスレッドを作成します。スレッドがいっぱいの場合は、拒否ポリシーに従って実行します

(2) 拒否ポリシー:

CallerRunsPolicy() : 元のスレッドが実行します
AbortPolicy(): 例外を直接スローします
DiscardPolicy(): 直接破棄します
DiscardOldestPolicy(): キュー内の最も古いアイテムを破棄します

1 ThreadPoolTaskScheduler はタスクスレッドプールを定期的にスケジュールし、非同期タスクを処理します

2 使用方法: ThreadPoolTaskScheduler の Bean を注入します

# (1) 設定ファイルの形式: ..

(2) 設定クラスの形式:

import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.ScheduledFuture; @Configuration public class ThreadPoolTaskSchedulerConfig { @Bean public ThreadPoolTaskScheduler threadPoolTaskScheduler() { final ThreadPoolTaskScheduler threadPoolTaskScheduler = new ThreadPoolTaskScheduler(); //设置等待任务在关机时l候完成 threadPoolTaskScheduler.setWaitForTasksToCompleteOnShutdown(true); //设置等待时间为60s threadPoolTaskScheduler.setAwaitTerminationSeconds(60); return threadPoolTaskScheduler; } }

ログイン後にコピー

3 ThreadPoolTaskScheduler のスケジュールされたタスクを使用します

通常のスレッドプールに使用:

submit( callable)、実行結果が必要です

submit(runnable)、実行結果は必要ありません
(1) スケジュールされたタスク

タスクの内容 Runnable を追加し、実行期間のトリガー/日付を設定します。トリガー式は Baidu を使用できます。

schedule(Runnable task,Trigger) schedule(Runnable task,Date)

ログイン後にコピー

(2) タスクを実行する間隔を指定します。前のタスクの完了から次のタスクの開始までの時間間隔をミリ秒単位で指定します。

scheduleWithFixedDelay(Runnable task,long delay)

ログイン後にコピー

(3) 実行タスクを一定の頻度で実行し、タスクの開始後一定間隔で新しいタスクを実行します。最後のタスクが完了した場合は、最後のタスクが完了するのを待ってから次のタスクを実行します。

scheduleAtFixedRate(Runnable task,long delay)

ログイン後にコピー

(4) スケジュールされたタスクのキャンセル:

スケジュールされたタスクが保存されるコレクションを設定します。スケジュールされたタスクの実行の結果は、ScheduledFuture です。オブジェクトをコレクションに格納し、コレクション内の ScheduledFuture< を取得します。?>オブジェクト。 cancel(true) スケジュールされたタスクをキャンセルします

import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler; import org.springframework.scheduling.support.CronTrigger; import org.springframework.stereotype.Service; import java.text.DateFormat; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.Date; import java.util.concurrent.*; @Service public class SchedulerService { @Autowired ThreadPoolTaskScheduler scheduler; /** * 常规线程池使用 */ public void tesScheduler1() throws ExecutionException, InterruptedException { //无返回值 final Future demo_scheduler1 = scheduler.submit(new Runnable() { @Override public void run() { System.out.println("demo runnable scheduler"); } }); //无返回值 final Future demo_scheduler2 = scheduler.submit(new Callable