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
Êþº¾4°
.^    ._    .`
1a    .b    .cd    efg
hi
 jk
j
lmn
j
o    .p
qr
s
t
u
v
wx
yz{
|}
~
|€
|‚ƒ
%„…
(†
‡    %ˆ‰
,†Š
‹Œ
.a
InnerClasses
logger
Lorg/slf4j/Logger;
instance
1Lcom/xxl/job/admin/core/thread/JobRegistryHelper;
registryOrRemoveThreadPool
)Ljava/util/concurrent/ThreadPoolExecutor;
registryMonitorThread
Ljava/lang/Thread;
toStop

Z
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
getInstance
3()Lcom/xxl/job/admin/core/thread/JobRegistryHelper;
start

e
 Ljava/lang/InterruptedException;
 StackMapTablex
registry
P(Lcom/xxl/job/core/biz/model/RegistryParam;)Lcom/xxl/job/core/biz/model/ReturnT;
 registryParam
*Lcom/xxl/job/core/biz/model/RegistryParam;
    Signature
d(Lcom/xxl/job/core/biz/model/RegistryParam;)Lcom/xxl/job/core/biz/model/ReturnT<Ljava/lang/String;>;
registryRemove
freshGroupRegistryInfo
-(Lcom/xxl/job/core/biz/model/RegistryParam;)V

access$000
()Lorg/slf4j/Logger;

access$100
4(Lcom/xxl/job/admin/core/thread/JobRegistryHelper;)Z
x0

access$200
^(Lcom/xxl/job/admin/core/thread/JobRegistryHelper;Lcom/xxl/job/core/biz/model/RegistryParam;)V
x1
<clinit>

SourceFile
JobRegistryHelper.javaQR;<34=>7856
'java/util/concurrent/ThreadPoolExecutorŽ
(java/util/concurrent/LinkedBlockingQueue=‘
1com/xxl/job/admin/core/thread/JobRegistryHelper$1=’
1com/xxl/job/admin/core/thread/JobRegistryHelper$2=“
java/lang/Thread
1com/xxl/job/admin/core/thread/JobRegistryHelper$3=”9:•–
=xxl-job, admin JobRegistryMonitorHelper-registryMonitorThread—˜E>™š›>œ>
java/lang/InterruptedExceptionžŸ ¡¢£ž¤¥¦§ž¨ž
"com/xxl/job/core/biz/model/ReturnT
Illegal Argument.=©
1com/xxl/job/admin/core/thread/JobRegistryHelper$4=Yª”«¬
1com/xxl/job/admin/core/thread/JobRegistryHelper$5
/com/xxl/job/admin/core/thread/JobRegistryHelper­®¯
java/lang/Object
java/util/concurrent/TimeUnit
SECONDS
Ljava/util/concurrent/TimeUnit;
(I)V
4(Lcom/xxl/job/admin/core/thread/JobRegistryHelper;)V
œ(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Ljava/util/concurrent/ThreadFactory;Ljava/util/concurrent/RejectedExecutionHandler;)V
(Ljava/lang/Runnable;)V
    setDaemon
(Z)V
setName
(Ljava/lang/String;)V
shutdownNow
()Ljava/util/List;
    interrupt
join

getMessage
()Ljava/lang/String;
org/slf4j/Logger
error
*(Ljava/lang/String;Ljava/lang/Throwable;)V
(com/xxl/job/core/biz/model/RegistryParam
getRegistryGroup
$org/springframework/util/StringUtils
hasText
(Ljava/lang/String;)Z
getRegistryKey
getRegistryValue
(ILjava/lang/String;)V
execute
SUCCESS
$Lcom/xxl/job/core/biz/model/ReturnT;
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;!.1
34
56789:B;<
=>
?A
*·*
µ*µ±@     A
B6    CD
?
²°
@

E>
?˜ 
Z*»Y
²
»Yз» Y*·»Y*··µ*»Y»Y*··µ*´¶*´¶*´¶±@%.:A€IR‚YƒA
ZB6
;>
?’-*µ*´¶W*´¶*´¶§L²+¶+¹ ±
@"†‰ ŒŽ‘,’A FG
-B6H^I 
JK?‘?+¶!¸"™+¶#¸"™ +¶$¸"š»%Y
ô&·'°*´»(Y*+·)¶*²+°@š›œ+¡;®A?B6?LM
HNO
PK?‘?+¶!¸"™+¶#¸"™ +¶$¸"š»%Y
ô&·'°*´»,Y*+·-¶*²+°@´µ¶·+»;ÆA?B6?LM
HNOQR
?5
±@
ËA
B6
LM
ST
?
²°
@
UV
?/

*´¬@
A
W6XY
?:*+·
±@
AW6ZM
[>
?/.¸/³».Y·0³±
@
\]2*,(