Êþº¾ 3j b «
|
? ¬ b b ® b ¯ b ° ±
|
¬ b ² ³
|
|
¬
|
´ µ b ¶
|
) ·
|
¸ ¹ º » b ¼ ½ ¾ ¿ À Á
|
¬ Â
|
Ã
|
Ä
|
Å
|
Æ º Ç
|
Ç È b É
|
Ê
|
Ë Ì Í
|
" Î ¾ Ï Ð Ñ
|
Ò Ó º Ô Õ
|
) Ö
|
+ ×
|
Ø Ù Ø Ú
|
Û Ü Þ
|
) à
|
) á
|
1 â
|
Ý ã ä
|
) å æ
|
ç è
|
) é ê ë
|
< ì
|
; í î
|
? ï
|
? ð
|
; ñ
|
? ò ó ô
|
ç õ Ë ö
|
÷ ø
|
Ë ù Ë ú û
|
ü ý
|
þ ÿ
|
P
|
|
U ¬
|
W
|
"
|
U Å
|
|
|
Ë
|
?
|
InnerClasses logger Lorg/slf4j/Logger; jobId I handler &Lcom/xxl/job/core/handler/IJobHandler; triggerQueue *Ljava/util/concurrent/LinkedBlockingQueue; Signature ULjava/util/concurrent/LinkedBlockingQueue<Lcom/xxl/job/core/biz/model/TriggerParam;>; triggerLogIdSet Ljava/util/Set; $Ljava/util/Set<Ljava/lang/Integer;>; toStop Z
|
stopReason Ljava/lang/String; running idleTimes <init> *(ILcom/xxl/job/core/handler/IJobHandler;)V Code LineNumberTable LocalVariableTable this #Lcom/xxl/job/core/thread/JobThread;
|
getHandler (()Lcom/xxl/job/core/handler/IJobHandler; pushTriggerQueue O(Lcom/xxl/job/core/biz/model/TriggerParam;)Lcom/xxl/job/core/biz/model/ReturnT; triggerParam )Lcom/xxl/job/core/biz/model/TriggerParam; StackMapTable c(Lcom/xxl/job/core/biz/model/TriggerParam;)Lcom/xxl/job/core/biz/model/ReturnT<Ljava/lang/String;>; (Ljava/lang/String;)V isRunningOrHasQueue ()Z run ()V e Ljava/lang/Throwable; triggerParamTmp
|
futureTask !Ljava/util/concurrent/FutureTask; 'Ljava/util/concurrent/TimeoutException; futureThread Ljava/lang/Thread; logFileName
|
stopResult $Lcom/xxl/job/core/biz/model/ReturnT; stringWriter Ljava/io/StringWriter; errorMsg executeResult LocalVariableTypeTable [Ljava/util/concurrent/FutureTask<Lcom/xxl/job/core/biz/model/ReturnT<Ljava/lang/String;>;>; 8Lcom/xxl/job/core/biz/model/ReturnT<Ljava/lang/String;>; Í Ó À î ó
|
access$000 K(Lcom/xxl/job/core/thread/JobThread;)Lcom/xxl/job/core/handler/IJobHandler; x0 <clinit>
|
SourceFile JobThread.java i j x r s v s w h g h (java/util/concurrent/LinkedBlockingQueue k l java/util/HashSet o p e f )>>>>>>>>>>> repeate trigger job, logId:{} !" "com/xxl/job/core/biz/model/ReturnT java/lang/StringBuilder repeate trigger job, logId: #$ #% &' x( ) * t u +, - java/lang/Throwable .' /01 23 45 'com/xxl/job/core/biz/model/TriggerParam 6 java/util/Date 78 x9: ;< =>? @AB -com/xxl/job/core/util/ShardingUtil$ShardingVO
|
ShardingVO C D xE FG K<br>----------- xxl-job job execute start -----------<br>----------- Param: H' java/lang/ObjectI JK L java/util/concurrent/FutureTask #com/xxl/job/core/thread/JobThread$1 xM xN java/lang/Thread xO P Q5 R %java/util/concurrent/TimeoutException +<br>----------- xxl-job job execute timeout JS T U job execute timeout VW X S<br>----------- xxl-job job execute end(finish) -----------<br>----------- ReturnT: #Y excutor idel times over limit.Z [( .com/xxl/job/core/biz/model/HandleCallbackParam x\] ^_ [job runningï¼killed] -<br>----------- JobThread toStop, stopReason: java/io/StringWriter java/io/PrintWriter x` ab $<br>----------- JobThread Exception: :<br>----------- xxl-job job execute end(error) ----------- 4c . [job not executed, in the job queue, killed.] d 1>>>>>>>>>>> xxl-job JobThread stoped, hashCode:{} ef !com/xxl/job/core/thread/JobThreadg hi java/lang/String java/util/Collections synchronizedSet (Ljava/util/Set;)Ljava/util/Set; getLogId ()I java/lang/Integer valueOf (I)Ljava/lang/Integer; java/util/Set contains (Ljava/lang/Object;)Z org/slf4j/Logger info '(Ljava/lang/String;Ljava/lang/Object;)V append -(Ljava/lang/String;)Ljava/lang/StringBuilder; (I)Ljava/lang/StringBuilder; toString ()Ljava/lang/String; (ILjava/lang/String;)V add SUCCESS size $com/xxl/job/core/handler/IJobHandler init
|
getMessage error *(Ljava/lang/String;Ljava/lang/Throwable;)V java/util/concurrent/TimeUnit SECONDS Ljava/util/concurrent/TimeUnit; poll 4(JLjava/util/concurrent/TimeUnit;)Ljava/lang/Object; remove getLogDateTim ()J (J)V 'com/xxl/job/core/log/XxlJobFileAppender makeLogFileName %(Ljava/util/Date;I)Ljava/lang/String; contextHolder "Ljava/lang/InheritableThreadLocal; java/lang/InheritableThreadLocal set (Ljava/lang/Object;)V "com/xxl/job/core/util/ShardingUtil getBroadcastIndex getBroadcastTotal (II)V setShardingVo 2(Lcom/xxl/job/core/util/ShardingUtil$ShardingVO;)V getExecutorParams !com/xxl/job/core/log/XxlJobLogger log ((Ljava/lang/String;[Ljava/lang/Object;)V getExecutorTimeout O(Lcom/xxl/job/core/thread/JobThread;Lcom/xxl/job/core/biz/model/TriggerParam;)V "(Ljava/util/concurrent/Callable;)V (Ljava/lang/Runnable;)V start get interrupt (Ljava/lang/Throwable;)V FAIL_TIMEOUT getCode execute 8(Ljava/lang/String;)Lcom/xxl/job/core/biz/model/ReturnT; FAIL -(Ljava/lang/Object;)Ljava/lang/StringBuilder; (com/xxl/job/core/executor/XxlJobExecutor removeJobThread )(IJLcom/xxl/job/core/biz/model/ReturnT;)V -com/xxl/job/core/thread/TriggerCallbackThread pushCallBack 3(Lcom/xxl/job/core/biz/model/HandleCallbackParam;)V (Ljava/io/Writer;)V printStackTrace (Ljava/io/PrintWriter;)V ()Ljava/lang/Object; destroy currentThread ()Ljava/lang/Thread; org/slf4j/LoggerFactory getLogger %(Ljava/lang/Class;)Lorg/slf4j/Logger; ! b ?
|
e f g h i j k l m n o p m q B r s t u v s w h x y z 7*· *µ *µ *µ *µ *,µ *» Y· µ *»
|
Y· ¸ µ ± { & * # & ' + , - ( . 6 / | 7 } ~ 7 g h 7 i j z / *´ ° { 1 | } ~ z ¶ c*´ +¶ ¸ ¹ 5² +¶ ¸ ¹ » Yô» Y· ¶ +¶ ¶ ¶ · °*´ +¶ ¸ ¹ W*´ +¶ W² ° { < = $ > E A V B _ C | c } ~ c
û E m r z G *µ *+µ ± { Q R
|
S | } ~ t u z M *´ *´ ¶ § ¬ { Z | } ~
@ z
|
g*´ ¶ !§ L² +¶ #+¹ $ *´ Î*µ *Y´ `µ LM*´ %² '¶ (À )L+Æ*µ *µ *´ +¶ ¸ ¹ * W» +Y+¶ ,· -+¶ ¸ .N² /-¶ 0» 1Y+¶ 2+¶ 3· 4¸ 5» Y· 6¶ +¶ 7¶ ¶ ½ 8¸ 9+¶ : z:+:» ;Y» <Y*· =· >:» ?Y· @:¶ A+¶ :
² '¶ BÀ M¶ C§ 5:E½ 8¸ 9¸ F» Y² G¶ HI· M¶ C§ :¶ C¿§ *´ +¶ 7¶ JM,Ç ² KM» Y· L¶ ,¶ M¶ ½ 8¸ 9§ *´ ¤ *´ N¸ O+Æz*´ » PY+¶ +¶ ,,· Q¸ R§]» Yô» Y· *´ ¶ S¶ ¶ · N» PY+¶ +¶ ,-· Q¸ R§&N*´ » Y· T¶ *´ ¶ ¶ ½ 8¸ 9» UY· V:-» WY· X¶ Y¶ Z:» Yô· M» Y· [¶ ¶ \¶ ¶ ½ 8¸ 9+Æ ³*´ » PY+¶ +¶ ,,· Q¸ R§ » Yô» Y· *´ ¶ S¶ ¶ · N» PY+¶ +¶ ,-· Q¸ R§ _:+Æ V*´ » PY+¶ +¶ ,,· Q¸ R§ 9» Yô» Y· *´ ¶ S¶ ¶ · : » PY+¶ +¶ , · Q¸ R¿§ý1*´ Æ S*´ ¶ I*´ ¶ ]À )L+Æ 7» Yô» Y· *´ ¶ ^¶ ¶ · M» PY+¶ +¶ ,,· Q¸ R§ÿ¬*´ ¶ _§ L² +¶ #+¹ $ ² `¸ a¹ ±
|
|
" µ ì ô D µ ì ô 2lÄ " 2l Ä3 AHK " { J R b e
|
c d h i $ j . l 0 m 2 p C q G r L s Q t b w u x | y | « ~ ² µ ¸ Ë Ö Û ì ñ ô ö ÿ # & ) 5 9 = W Z ¡c ¢l ±p ³w µ ¸® ¹Á ºÄ ¥Å ¦Ì §é ªò «ÿ ¬ ¯3 ±7 ³> µT ¸u ¹ º ± ³ µ® ¸Ð ¹ä ¼ç ½ê Àû Á Â
|
Ä+ Å> ÇA ËH ÎK ÌL ÍY Ðf Ñ | ¶ ¸ 4 Ë ! ö µ q u â u ® ò A - u Å n u Ð 0· 2µ + 8 L g } ~ > Ë ! ® u Ð 2µ +
m J ÿ Û ¡ ¢ £ ¤g ú ú v ü $ ú jv ÿ " ¡ 5ÿ û SI ¥ ¦ z / *´ ° { | § ~ ¨ z ! b¸ c³ ± { © ª d < 1 Ý ß
|
