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
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
Êþº¾4®    (c    (d    (e
+f    (g    (h
ijê`k
 
fl
mn
mo<    pqr
st
u
v
mwx
u
yz{|
}~€
‚ƒ
!„
…    (†
(‡
(ˆ
(‰Š
‹Œ
(f
InnerClasses
logger
Lorg/slf4j/Logger;
fastTriggerPool
)Ljava/util/concurrent/ThreadPoolExecutor;
slowTriggerPool
minTim

J
jobTimeoutCountMap
$Ljava/util/concurrent/ConcurrentMap;
    Signature
dLjava/util/concurrent/ConcurrentMap<Ljava/lang/Integer;Ljava/util/concurrent/atomic/AtomicInteger;>;
helper
4Lcom/xxl/job/admin/core/thread/JobTriggerPoolHelper;
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
start
stop

addTrigger
k(ILcom/xxl/job/admin/core/trigger/TriggerTypeEnum;ILjava/lang/String;Ljava/lang/String;Ljava/lang/String;)V
jobId

I
triggerType
0Lcom/xxl/job/admin/core/trigger/TriggerTypeEnum;
failRetryCount
executorShardingParam
Ljava/lang/String;
 executorParam
addressList
triggerPool_
jobTimeoutCount
+Ljava/util/concurrent/atomic/AtomicInteger;
 StackMapTablel
toStart
toStop
trigger

access$000
()Lorg/slf4j/Logger;

access$100
7(Lcom/xxl/job/admin/core/thread/JobTriggerPoolHelper;)J
x0

access$102
8(Lcom/xxl/job/admin/core/thread/JobTriggerPoolHelper;J)J
x1

access$200
Z(Lcom/xxl/job/admin/core/thread/JobTriggerPoolHelper;)Ljava/util/concurrent/ConcurrentMap;
<clinit>

SourceFile
JobTriggerPoolHelper.java4523-.:;/010Ž
&java/util/concurrent/ConcurrentHashMap
'java/util/concurrent/ThreadPoolExecutor‘’“”•–—˜
(java/util/concurrent/LinkedBlockingQueue:™
4com/xxl/job/admin/core/thread/JobTriggerPoolHelper$1:š:›œ•
4com/xxl/job/admin/core/thread/JobTriggerPoolHelper$2ž
7>>>>>>>>> xxl-job trigger thread pool shutdown success.Ÿ ¡¢£¤¥¦§
)java/util/concurrent/atomic/AtomicInteger¦•
4com/xxl/job/admin/core/thread/JobTriggerPoolHelper$3:¨©ª89@;A;BC
2com/xxl/job/admin/core/thread/JobTriggerPoolHelper«¬­
java/lang/Object
java/lang/System
currentTimeMillis
()J
-com/xxl/job/admin/core/conf/XxlJobAdminConfig
getAdminConfig
1()Lcom/xxl/job/admin/core/conf/XxlJobAdminConfig;
getTriggerPoolFastMax
()I
java/util/concurrent/TimeUnit
SECONDS
Ljava/util/concurrent/TimeUnit;
(I)V
7(Lcom/xxl/job/admin/core/thread/JobTriggerPoolHelper;)V
m(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Ljava/util/concurrent/ThreadFactory;)V
getTriggerPoolSlowMax
shutdownNow
()Ljava/util/List;
org/slf4j/Logger
info
(Ljava/lang/String;)V
java/lang/Integer
valueOf
(I)Ljava/lang/Integer;
"java/util/concurrent/ConcurrentMap
get
&(Ljava/lang/Object;)Ljava/lang/Object;
Ÿ(Lcom/xxl/job/admin/core/thread/JobTriggerPoolHelper;ILcom/xxl/job/admin/core/trigger/TriggerTypeEnum;ILjava/lang/String;Ljava/lang/String;Ljava/lang/String;)V
execute
(Ljava/lang/Runnable;)V
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;!(+
-./010B23B45
67
89
:;
<_
%*·*
µ*
µ*¸mµ*»
Y·µ
±=    AB>
%?9
@;
<‘
W*»Y
¸ ¶²»Yè·»Y*··µ*»Y
¸ ¶²»Yз»Y*··µ±=+)2+V5>
W?9
A;
<Q
*´¶W*´¶W²¹±=:;<=>
?9
BC
<ã
    D*´:*´
¸¹À:ƶ 
¤    *´:»!Y*,·"¶#±=PQR'S-WCx>\    D?9DDE
DFGDHEDIJDKJDLJ>M0,NOP
ý-QR    S;
<#
²$¶%±
=
€    T;
<#
²$¶&±
=
„…    UC
<o²$+-¶'±=
‘’>>DEFG
HEIJKJLJVW
<
²°
=
XY
</
*´­=
>
Z9[\
<;*]µ­=
>Z9]3
^_
</

*´
°=
>
Z9`;
</(¸)³»(Y·*³$±
=
}ab,!