Êþº¾ 4
chushihua/lunxun java/lang/Object isRunning Z isPaused
|
shouldStop +Ljava/util/concurrent/atomic/AtomicBoolean; pollingThread Ljava/lang/Thread; pollingInterval I MIN_SLOT ConstantValue MAX_SLOT < SERIAL_CHECK_INTERVAL lastSerialCheckTime J serialConnected queryCommandCache Ljava/util/Map; Signature 6Ljava/util/Map<Ljava/lang/Integer;Ljava/lang/String;>; DEBUG_ENABLED <clinit> ()V Code ! # % )java/util/concurrent/atomic/AtomicBoolean
|
$ ' ( ) <init> (Z)V + - / 1 3 &java/util/concurrent/ConcurrentHashMap
|
2 5 ( 7 9 LineNumberTable LocalVariableTable
|
5 this Lchushihua/lunxun; checkSerialConnection ()Z
|
B D C java/lang/System E F currentTimeMillis ()J
|
J L K chuankou/Sendmsg M @
|
isPortOpen B O P Q err Ljava/io/PrintStream; S $串å£è¿æ¥å¤±è´¥ - 串å£æªæå¼
|
U W V java/io/PrintStream X Y println (Ljava/lang/String;)V [ java/lang/StringBuilder ] 串å£è¿æ¥æ£æ¥å¼å¸¸:
|
Z _ ( Y
|
a c b java/lang/Exception d e
|
getMessage ()Ljava/lang/String;
|
Z g h i append -(Ljava/lang/String;)Ljava/lang/StringBuilder;
|
Z k l e toString currentTime result e Ljava/lang/Exception; StackMapTable checkSerialConnectionWithRetry
|
t ? @ è
|
x z y java/lang/Thread { | sleep (J)V
|
x ~ currentThread ()Ljava/lang/Thread;
|
x interrupt
java/lang/InterruptedException i Ljava/lang/InterruptedException; startPolling
|
r @ *串å£æªè¿æ¥ï¼æ æ³å¯å¨è½®è¯¢æ¥è¯¢
|
loadPollingIntervalFromConfig
|
$ ) set chushihua/lunxun$PollingTask
|
( !(Lchushihua/lunxun$PollingTask;)V CardSlot-Polling-Thread
|
x ( )(Ljava/lang/Runnable;Ljava/lang/String;)V
|
|
x ¡ ) setDaemon
|
x £ ¤ start ¦ )å¯å¨è½®è¯¢æ¥è¯¢çº¿ç¨æ¶åçå¼å¸¸: stopPolling ¸
|
x « ¬ | join
|
x ® ¯ @ isAlive ± @轮询线ç¨æªå¨3ç§å
åæ¢ï¼æ 记为å®æ¤çº¿ç¨å¹¶å¿½ç¥ ³ åæ¢è½®è¯¢æ¥è¯¢æ¶è¢«ä¸æ:
|
c ¶ #åæ¢è½®è¯¢çº¿ç¨æ¶åçå¼å¸¸: ¸ java/lang/Throwable pausePolling resumePolling ¼ *串å£æªè¿æ¥ï¼æ æ³æ¢å¤è½®è¯¢æ¥è¯¢
|
¾ ¿ notifyAll Á java/lang/Class isPolling isSerialConnected setPollingInterval (I)V Ç è½®è¯¢é´éä¸è½å°äº10ms
|
É Ê @ restartPolling interval getPollingInterval ()I
|
Ï § @ È
|
Ó @
|
Õ × Ö chushihua/Chushihua Ø Ù getInstance ()Lchushihua/Chushihua;
|
Õ Û Ü @ isInitialized
|
Õ Þ ß à getMachineConfig ()Lhome/MachineConfig;
|
â ä ã home/MachineConfig Ì Í æ å 载轮询é´éé
置失败: configSystem Lchushihua/Chushihua; machineConfig Lhome/MachineConfig; getCachedQueryCommand (I)Ljava/lang/String;
|
î ð ï java/lang/Integer ñ ò valueOf (I)Ljava/lang/Integer; ô õ ö apply ()Ljava/util/function/Function; ø ú ù java/util/Map û ü computeIfAbsent C(Ljava/lang/Object;Ljava/util/function/Function;)Ljava/lang/Object; þ java/lang/String
|
slotNumber clearQueryCache ø clear sendImmediateQuery (I)Z å¡æ§½ç¼å·å¿
é¡»å¨1-60ä¹é´ *串å£æªè¿æ¥ï¼æ æ³åéæ¥è¯¢æ令
|
ë ì
|
ý e trim
|
ý @ isEmpty
|
J sendMessage (Ljava/lang/String;)Z +ç«å³æ¥è¯¢å¤±è´¥ - åéæ令å°å¡æ§½
|
Z h (I)Ljava/lang/StringBuilder; 失败 ;ç«å³æ¥è¯¢å¤±è´¥ - çæçæ¥è¯¢æ令为空ï¼å¡æ§½: ç«å³æ¥è¯¢å¡æ§½ " æ¶åçå¼å¸¸: queryCommand Ljava/lang/String;
|
sendResult sendImmediateQueryToAll( 0串å£æªè¿æ¥ï¼æ æ³åéæ¹éæ¥è¯¢æ令
|
$* + @ get
|
-/. java/lang/Math 01 min (II)I
|
3 2 successCount batchSize
|
totalSlots
|
batchStart batchEnd slot setSerialConnected> )串å£è¿æ¥ç¶æ已设置为: æªè¿æ¥
|
@ ¹ @ connected getPollingStatusD å·²åæ¢F å·²æåH è¿è¡ä¸J å·²è¿æ¥L æªè¿æ¥ øN O Í sizeQ Q轮询ç¶æ: %s, 串å£: %s, é´é: %dms, æ令ç¼å: %d, å¡æ§½èå´: %d-%d
|
ýS TU format 9(Ljava/lang/String;[Ljava/lang/Object;)Ljava/lang/String; status serialStatus cacheSize setPollingPaused (Z)Z paused getPerformanceStats^ 0æ¥è¯¢æ令ç¼å大å°: %d, 轮询é´é: %dms isDEBUG_ENABLED setDEBUG_ENABLED dEBUG_ENABLED access$0 access$1 -()Ljava/util/concurrent/atomic/AtomicBoolean; access$2 access$3 access$4 access$5 access$6
|
SourceFile lunxun.java BootstrapMethods
|
npo "java/lang/invoke/LambdaMetafactory qr metafactory Ì(Ljava/lang/invoke/MethodHandles$Lookup;Ljava/lang/String;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodType;Ljava/lang/invoke/MethodHandle;Ljava/lang/invoke/MethodType;)Ljava/lang/invoke/CallSite;m &(Ljava/lang/Object;)Ljava/lang/Object;t
|
wyx publicway/QueryData z ì queryDatav '(Ljava/lang/Integer;)Ljava/lang/String;| InnerClasses PollingTask %java/lang/invoke/MethodHandles$Lookup java/lang/invoke/MethodHandles Lookup ! J J
|
|
|
|
|
k /³ ³ "» $Y· &³ *d³ , ³ .³ 0» 2Y· 4³ 6³ 8± : " # * & ; ( / *· <± : ; = > ? @ î X¸ A? ² .e G ² 0¬ ³ .¸ I=
|
³ 0§ 0² NR¶ T³ 0§ !M² N» ZY\· ^,¶ `¶ f¶ j¶ T³ 0² 0¬ 3 6 a : : . / 0 3 7 9 = $ > ' ? / @ 3 B 7 C P D T G ; T m n 7 o p q ü ü ÿ a
|
r @ );§ ¸ s ¬ u¸ w§ L¸ }¶ ¬ ¡ÿᬠ: & N O P S T U V N ' Y ; % o q ü H @ ø t² ¬¸ ² N¶ T¬¸ ³ ³ "² *¶ » xY» Y· · ³ ² ¶ ² ¶ ¢¬K² N» ZY¥· ^*¶ `¶ f¶ j¶ T³ ² *¶ ¬ * K M a : J a c g h i m o p # q * t > u E v K z M { N | g } k ~ r ; N & o p q t a § @ j £² ¬² *¶ ³ ³ "² Æ ² ¶ ² ¨¶ ª² ¶ d² N°¶ T² ¶ § RK² N» ZY²· ^*¶ ´¶ f¶ j¶ T¸ }¶ ³ § /K² N» ZYµ· ^*¶ `¶ f¶ j¶ T³ § L³ +¿³ ² *¶ ¬ # D G # D n a # g n : b # , 5 = D H a g ¡ n o ¡ ¡ ¢ ¡ ¥ ¡ § ; H o o o p q ~ f a` · ¹ @ T ² ¬² " ¬³ "¬ : ¯ ³ ¶ º ½ ¿ ; q º @ ¯ 8² ¬² " ¬¸ ² N»¶ T¬³ "YK¶ ½*ç *ÿ¬ ) 0 3 3 5 3 : 2 Ç É Ì Î Ò Ó Ô × $ Ø ) Ù . Ø 6 Ü ; q ÿ À ·ú  @ $ ² ¬ : ä ; @ $ ² "¬ : ì ; à @ $ ² 0¬ : ô ; Ä Å j
|
¢ ² Nƶ T±³ ,² ¸ ÈW± : ü ý þ ; Ë q Ì Í $ ² ,¬ : ; Ê @ g ¸ ÎW и w§
|
K¸ }¶ ¸ Ò¬
|
:
|
; o q M
|
5¸ ÔK*¶ Ú ,*¶ ÝL+¶ á³ ,§ K² N» ZYå· ^*¶ `¶ f¶ j¶ T± a : ( ) * + 0 1 44 ; ç è é ê o p q Z a
|
ë ì ? ² 6¸ íº ó ¹ ÷ À ý° : : ; ÿ - ² 6¹ ± :
|
A C ; h ¤¡ <¤ ² N¶ T¬¸ ² N¶ T¬¸
|
L+Æ 7+¶ ¶ -+¸= ¬² N» ZY· ^¶¶ f¶ j¶ T¬² N» ZY · ^¶¶ j¶ T¬L² N» ZY · ^¶!¶ f+¶ `¶ f¶ j¶ T¬ ' C } a E b } a d { } a : J Ü Ý Þ â ã %ä 'é ,ë :í ?ï Có Eõ bö dù {ú }ý ~þ ¢ÿ ; * ¤ ÿ , Q#$ ? %% ~ & o p q
|
ý ýú ÿ a & Í g w¸ ² N'¶ T¬;<<=>§ U² *¶) § O `d<¸,6 6§ ¸2 ¤ÿî<¢ 4¸ w§ :¸ }¶ § `> <¤ÿ«¬ W ] ` : V
|
& ) 5 ; C F P# W% ]& b' h( k u. ; H d6 b7 _8 [9 5 6: 8 ; b o q ,
|
ÿ ý
|
ÿ ú
|
ú < ) s (³ 0¸ A³ . ² N=¶ T² ² " ¸?W± : 6 7
|
9 < > #? 'B ; (A q ' B e ù j²
|
CK§ ² "
|
EK§ GK² 0 I§ KL² 6¹M =P½ Y*SY+SY² ,¸ íSY ¸ íSY¸ íSY<¸ íS¸R° : . J K
|
L M N O R .S 7U AV fU ; 4
|
V$ V$ LV$ . <W$ 7 3X q ü ý B ý YZ â J² ¬ ² " ³ "¬¬² " +¸ ² N»¶ T¬³ "YL¶ ½+ç +ÿ¬¬ 9 @ C C E C : F _ a d f g i l p r &s .t 0w 4x 9y >x F| H ; J[ q ÿ À ·ú \ e J "]½ Y² 6¹M ¸ íSY² ,¸ íS¸R° : ; _ @ $ ² 8¬ : ; ` ) 3 ³ 8± :
|
; a b @ $ ² ¬ : ; cd $ ² *° : ; e @ $ ² "¬ : ; f @ $ ¸ ¬ : M ; g Í $ ² ,¬ : ; h ì % ¸
|
° : 9 ; i ) % ³ 0± : ; j kl s u{}~
|
|
