Êþº¾ 4 þ < t
|
= u
|
r v
|
w x
|
w y z { |
|
w } ~
|
|
u
|
u
|
|
|
(
|
|
|
u
|
|
|
#
|
|
& u
|
&
|
&
|
( ¡
|
( ¢
|
# £
|
# ¤ z ¥ ¦
|
r § ¨ © ª « ¬
|
« ® ¯ © ° ± ² ³ this$0 1Lcom/xxl/job/admin/core/thread/JobRegistryHelper; <init> 4(Lcom/xxl/job/admin/core/thread/JobRegistryHelper;)V Code LineNumberTable LocalVariableTable this InnerClasses 3Lcom/xxl/job/admin/core/thread/JobRegistryHelper$3; run ()V appname Ljava/lang/String; registryList Ljava/util/List; item -Lcom/xxl/job/admin/core/model/XxlJobRegistry; addressListSB Ljava/lang/StringBuilder; addressListStr group *Lcom/xxl/job/admin/core/model/XxlJobGroup; ids appAddressMap Ljava/util/HashMap; list groupList e Ljava/lang/Exception; Ljava/lang/InterruptedException; LocalVariableTypeTable $Ljava/util/List<Ljava/lang/String;>; %Ljava/util/List<Ljava/lang/Integer;>; KLjava/util/HashMap<Ljava/lang/String;Ljava/util/List<Ljava/lang/String;>;>; ?Ljava/util/List<Lcom/xxl/job/admin/core/model/XxlJobRegistry;>; <Ljava/util/List<Lcom/xxl/job/admin/core/model/XxlJobGroup;>; StackMapTable ´ ± ¦ ®
|
SourceFile JobRegistryHelper.java EnclosingMethod µ ¶ J ? @ A J · ¸ ¹ º » ¼ ½ ¾ ¿ À Á Â Ã Ä %com/xxl/job/core/enums/RegistryConfig java/util/Date Å Æ Ç È É Ê Ë java/util/HashMap Ì Ç Í Î ´ Ï Â Ð Ñ +com/xxl/job/admin/core/model/XxlJobRegistry Ò Ô Õ Ö × Ø × Ù Ú Û × Ü Ý java/util/List java/util/ArrayList Þ × ß Ú à Ú á â (com/xxl/job/admin/core/model/XxlJobGroup ã × ä å æ java/lang/StringBuilder java/lang/String ç è , é × ê É ë ì í î ï ð ñ ò java/lang/Exception ó ô 9>>>>>>>>>>> xxl-job, job registry monitor thread error:{} õ ö ÷ ø ù ú û ü java/lang/InterruptedException 5>>>>>>>>>>> xxl-job, job registry monitor thread stop ý î 1com/xxl/job/admin/core/thread/JobRegistryHelper$3 java/lang/Object java/lang/Runnable java/util/Iterator /com/xxl/job/admin/core/thread/JobRegistryHelper start
|
access$100 4(Lcom/xxl/job/admin/core/thread/JobRegistryHelper;)Z -com/xxl/job/admin/core/conf/XxlJobAdminConfig getAdminConfig 1()Lcom/xxl/job/admin/core/conf/XxlJobAdminConfig; getXxlJobGroupDao (()Lcom/xxl/job/admin/dao/XxlJobGroupDao; $com/xxl/job/admin/dao/XxlJobGroupDao findByAddressType (I)Ljava/util/List; isEmpty ()Z getXxlJobRegistryDao +()Lcom/xxl/job/admin/dao/XxlJobRegistryDao; 'com/xxl/job/admin/dao/XxlJobRegistryDao findDead #(ILjava/util/Date;)Ljava/util/List; size ()I
|
removeDead (Ljava/util/List;)I findAll iterator ()Ljava/util/Iterator; hasNext next ()Ljava/lang/Object; 0com/xxl/job/core/enums/RegistryConfig$RegistType
|
RegistType EXECUTOR 2Lcom/xxl/job/core/enums/RegistryConfig$RegistType; name ()Ljava/lang/String; getRegistryGroup equals (Ljava/lang/Object;)Z getRegistryKey get &(Ljava/lang/Object;)Ljava/lang/Object; getRegistryValue contains add put 8(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
|
getAppname java/util/Collections sort (Ljava/util/List;)V append -(Ljava/lang/String;)Ljava/lang/StringBuilder; toString length substring (II)Ljava/lang/String; setAddressList (Ljava/lang/String;)V setUpdateTime (Ljava/util/Date;)V update -(Lcom/xxl/job/admin/core/model/XxlJobGroup;)I
|
access$000 ()Lorg/slf4j/Logger; org/slf4j/Logger error *(Ljava/lang/String;Ljava/lang/Throwable;)V java/util/concurrent/TimeUnit SECONDS Ljava/util/concurrent/TimeUnit; sleep (J)V info < = > ? @ A B C >
|
*+µ *· ± D : E
|
F H
|
? @ I J C $ ì*´ ¸ Ú¸ ¶ ¹ L+Æ+¹ ¸ ¶ Z»
|
Y· ¹ M,Æ ,¹ ¸ ¶ ,¹ W» Y· N¸ ¶ Z»
|
Y· ¹ :Æ {¹ :¹ h¹ À :² ¶ ¶ ¶ H¶ :-¶ À :Ç » Y· :¶ ¹ ¶ ¹ ! W-¶ "W§ÿ+¹ :¹ ¦¹ À #:-¶ $¶ À ::Æ `¹ V¸ %» &Y· ': ¹ :
|
|
¹
|
¹ À (: ¶ )*¶ )W§ÿÝ ¶ +:¶ ,d¶ -:¶ .»
|
Y· ¶ /¸ ¶ ¹ 0 W§ÿV§ L*´ ¸ ¸ 23+¹ 4 ² 5 6¶ 8§þ;L*´ ¸ ¸ 23+¹ 4 §þ"¸ 2:¹ ; ±
|
£¦ 1¼ÅÈ 9 D º . =
|
@ A $ D 9 E F F S J [ K q L v M N ¦ O P ¸ Q ½ R Æ U Õ V â X ë Z î ^ _ ` a, b1 c: dY ef fi gp h j k m n£ t¦ p§ q± r¼ vÅ {È wÉ xÓ yÞ {á }ë ~ E > K L ¸ 3 M N V O P Y O L : E Q R M N S L T U 9j V N [H W X q2 Y N Z N § [ \ É [ ] ì F H ^ > ¸ 3 M _ M _ 9j V ` [H W a q2 Y b Z c d t ý R e eþ + f e gþ F h i eø ú ü gÿ L j e e f e g k e i l g ú %ú ÿ # j B mK n o p q r s G < Ó@
|
