first commit

xm

2024-06-14 722af26bc6fec32bb289b1df51a9016a4935610f

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
Êþº¾4o
:
;<
;=    >?
:
@
A    B
CD
E
CF
GI
:
KLN
:P
Q
R
S
TUV
InnerClasses
core

I
threadPoolProperties
9Lcom/dl/framework/config/properties/ThreadPoolProperties;
RuntimeVisibleAnnotations
8Lorg/springframework/beans/factory/annotation/Autowired;
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
*Lcom/dl/framework/config/ThreadPoolConfig;
threadPoolTaskExecutor
D()Lorg/springframework/scheduling/concurrent/ThreadPoolTaskExecutor;
executor
BLorg/springframework/scheduling/concurrent/ThreadPoolTaskExecutor;
-Lorg/springframework/context/annotation/Bean;
name
HLorg/springframework/boot/autoconfigure/condition/ConditionalOnProperty;
prefix
thread-pool
enabled
havingValue
true
scheduledExecutorService
1()Ljava/util/concurrent/ScheduledExecutorService;

SourceFile
ThreadPoolConfig.java
6Lorg/springframework/context/annotation/Configuration;"#WXYZ[
@org/springframework/scheduling/concurrent/ThreadPoolTaskExecutor\]^]_`[a]b[c]d
8java/util/concurrent/ThreadPoolExecutor$CallerRunsPolicy
CallerRunsPolicyef
*com/dl/framework/config/ThreadPoolConfig$1g
>org/apache/commons/lang3/concurrent/BasicThreadFactory$Builder
Builder
schedule-pool-%dhijklm"n
(com/dl/framework/config/ThreadPoolConfig
java/lang/Object
java/lang/Runtime

getRuntime
()Ljava/lang/Runtime;
availableProcessors
()I
setCorePoolSize
(I)V
setMaxPoolSize
7com/dl/framework/config/properties/ThreadPoolProperties
getQueueCapacity
setQueueCapacity
getKeepAliveSeconds
setKeepAliveSeconds
'java/util/concurrent/ThreadPoolExecutor
setRejectedExecutionHandler
2(Ljava/util/concurrent/RejectedExecutionHandler;)V
6org/apache/commons/lang3/concurrent/BasicThreadFactory
 namingPattern
T(Ljava/lang/String;)Lorg/apache/commons/lang3/concurrent/BasicThreadFactory$Builder;
daemon
C(Z)Lorg/apache/commons/lang3/concurrent/BasicThreadFactory$Builder;
build
:()Lorg/apache/commons/lang3/concurrent/BasicThreadFactory;
(Lcom/dl/framework/config/ThreadPoolConfig;ILjava/util/concurrent/ThreadFactory;Ljava/util/concurrent/RejectedExecutionHandler;)V!
 
!
"#
$?
*·
*¸¶`µ±%
&
'(
)*$‰=»Y·L+*´¶+*´h¶+*´    ¶
¶+*´    ¶¶ +»Y·¶+°%#$%&%'0(;)&='(5+,
 $-
.[
s)/0s1.[
s23s456$Y
'»Y**´»Y·¶¶¶»Y··°%12&1&
''( 
-
.[
s578 
9HJ    MO