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
40
41
42
43
44
45
46
47
Êþº¾4è
<u    <v    <w
?x    <y    <z{    |}~
€
 ‚

ƒ„…

†    <‡
ˆ‰
Š
‹
Œ

Ž
‘’“
!”
•    )–
—˜
—™
š›œžŸ
) 
¡¢£¤
.x
¡¥
.¦§
š¥¨
4x
¡©
š¢
¡ª
.«
¡¬
­®¯
°±
<x²
InnerClasses
logger
Lorg/slf4j/Logger;
instance
1Lcom/xxl/job/admin/core/thread/JobCompleteHelper;
callbackThreadPool
)Ljava/util/concurrent/ThreadPoolExecutor;
 monitorThread
Ljava/lang/Thread;
toStop

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

e
 Ljava/lang/InterruptedException;
 StackMapTable
callback
6(Ljava/util/List;)Lcom/xxl/job/core/biz/model/ReturnT;
callbackParamList
Ljava/util/List;
LocalVariableTypeTable
BLjava/util/List<Lcom/xxl/job/core/biz/model/HandleCallbackParam;>;
    Signature
|(Ljava/util/List<Lcom/xxl/job/core/biz/model/HandleCallbackParam;>;)Lcom/xxl/job/core/biz/model/ReturnT<Ljava/lang/String;>;
V(Lcom/xxl/job/core/biz/model/HandleCallbackParam;)Lcom/xxl/job/core/biz/model/ReturnT;
handleCallbackParam
0Lcom/xxl/job/core/biz/model/HandleCallbackParam;
log
(Lcom/xxl/job/admin/core/model/XxlJobLog;
    handleMsg
Ljava/lang/StringBuffer;³¤
j(Lcom/xxl/job/core/biz/model/HandleCallbackParam;)Lcom/xxl/job/core/biz/model/ReturnT<Ljava/lang/String;>;

access$000
()Lorg/slf4j/Logger;

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

access$200
‡(Lcom/xxl/job/admin/core/thread/JobCompleteHelper;Lcom/xxl/job/core/biz/model/HandleCallbackParam;)Lcom/xxl/job/core/biz/model/ReturnT;
x1
<clinit>

SourceFile
JobCompleteHelper.javaX`IJABKLEFCD
'java/util/concurrent/ThreadPoolExecutor´µ¶
(java/util/concurrent/LinkedBlockingQueueK·
1com/xxl/job/admin/core/thread/JobCompleteHelper$1K¸
1com/xxl/job/admin/core/thread/JobCompleteHelper$2K¹
java/lang/Thread
1com/xxl/job/admin/core/thread/JobCompleteHelper$3KºGH»¼
$xxl-job, admin JobLosedMonitorHelper½¾SL¿ÀÁLÂL
java/lang/InterruptedExceptionÃÄÅÆÇ
1com/xxl/job/admin/core/thread/JobCompleteHelper$4KÈɺÊËÌÍÎÏÐÑÒÓÔÕÖ
"com/xxl/job/core/biz/model/ReturnT
log item not found.K׳ØÙ
log repeate callback.
java/lang/StringBufferÚÄÛÜ
<br>
java/util/DateÝÞß·àÄá¾âãä
/com/xxl/job/admin/core/thread/JobCompleteHelperåæç
java/lang/Object
&com/xxl/job/admin/core/model/XxlJobLog
java/util/concurrent/TimeUnit
SECONDS
Ljava/util/concurrent/TimeUnit;
(I)V
4(Lcom/xxl/job/admin/core/thread/JobCompleteHelper;)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
D(Lcom/xxl/job/admin/core/thread/JobCompleteHelper;Ljava/util/List;)V
execute
SUCCESS
$Lcom/xxl/job/core/biz/model/ReturnT;
-com/xxl/job/admin/core/conf/XxlJobAdminConfig
getAdminConfig
1()Lcom/xxl/job/admin/core/conf/XxlJobAdminConfig;
getXxlJobLogDao
&()Lcom/xxl/job/admin/dao/XxlJobLogDao;
.com/xxl/job/core/biz/model/HandleCallbackParam
getLogId
()J
"com/xxl/job/admin/dao/XxlJobLogDao
load
+(J)Lcom/xxl/job/admin/core/model/XxlJobLog;
(ILjava/lang/String;)V
 getHandleCode
()I
getHandleMsg
append
,(Ljava/lang/String;)Ljava/lang/StringBuffer;
 setHandleTime
(Ljava/util/Date;)V
 setHandleCode
toString
setHandleMsg
/com/xxl/job/admin/core/complete/XxlJobCompleter
updateHandleInfoAndFinish
+(Lcom/xxl/job/admin/core/model/XxlJobLog;)I
org/slf4j/LoggerFactory
    getLogger
%(Ljava/lang/Class;)Lorg/slf4j/Logger;!<?
AB
CDEFGHBIJ

KL
MA
*·*
µ*µ±N!    #O
PD    QR
M
²°
N

SL
M˜ 
Z*»Y²
»Y¸·» Y*·»Y*··µ*»Y»Y*··µ*´¶*´¶*´¶±N(.>AuIvRwYxO
ZPD
IL
M’-*µ*´¶W*´¶*´¶§L²+¶+¹ ±
N"{~ ƒ†„…,‡O TU
-PDV^W 
XYM^*´»!Y*+·"¶#²$°N
Ž™OPDZ[
\
Z]
^_X`M
†¸%¶&+¶'¹(M,Ç»)Y
ô*·+°,¶,ž»)Y
ô-·+°».Y·/N,¶0Æ-,¶0¶12¶1W+¶3Æ-+¶3¶1W,»4Y·5¶6,+¶7¶8,-¶9¶:,¸;W²$°N>žŸ !¢(£5§=¨D©R«Y¬b°m±u²}³‚µO*†PD†ab
vcd=IefVü!güh^ijk
M
²°
N
lm
M/

*´¬N
O
nDop
M:*+·
°N
OnDqb
rL
M/<¸=³»<Y·>³±
N
st@"!