Êþº¾ 4 Ö < z {
|
4 | }
|
~
|
|
6
|
|
4
|
|
4 4 4
|
|
4 4
|
|
|
|
|
|
|
|
6
|
6
|
6
|
6 ¡ 4 ¢ £
|
¤ ¥ ¦
|
§ ¨ © ª
|
6 « ¬
|
4 ® ¯ ° ±
|
² ³ ´ logger Lorg/slf4j/Logger; taskLock *Ljava/util/concurrent/locks/ReentrantLock; unpaused &Ljava/util/concurrent/locks/Condition; submitCnd maxTaskCount I currentTaskCount activeTaskCount <init> (I)V Code LineNumberTable LocalVariableTable this =Lcom/yami/trading/common/executor/BlockingThreadPoolExecutor; fixedThreadPoolSize %(IIJLjava/util/concurrent/TimeUnit;)V corePoolSize maximumPoolSize keepAliveTime J unit Ljava/util/concurrent/TimeUnit; submit 3(Ljava/lang/Runnable;)Ljava/util/concurrent/Future; e Ljava/lang/InterruptedException; task Ljava/lang/Runnable; submitResult Ljava/util/concurrent/Future; LocalVariableTypeTable Ljava/util/concurrent/Future<*>; StackMapTable µ Signature 6(Ljava/lang/Runnable;)Ljava/util/concurrent/Future<*>; E(Ljava/lang/Runnable;Ljava/lang/Object;)Ljava/util/concurrent/Future; result Ljava/lang/Object; TT; "Ljava/util/concurrent/Future<TT;>; Q<T:Ljava/lang/Object;>(Ljava/lang/Runnable;TT;)Ljava/util/concurrent/Future<TT;>; >(Ljava/util/concurrent/Callable;)Ljava/util/concurrent/Future; Ljava/util/concurrent/Callable; $Ljava/util/concurrent/Callable<TT;>; ^<T:Ljava/lang/Object;>(Ljava/util/concurrent/Callable<TT;>;)Ljava/util/concurrent/Future<TT;>; beforeExecute )(Ljava/lang/Thread;Ljava/lang/Runnable;)V t Ljava/lang/Thread; r afterExecute ,(Ljava/lang/Runnable;Ljava/lang/Throwable;)V Ljava/lang/Throwable; getRunningTaskCount ()I getUnFinishedTaskCount count <clinit> ()V
|
SourceFile BlockingThreadPoolExecutor.java ¶ · P B J 'java/util/concurrent/ArrayBlockingQueue B C 3java/util/concurrent/ThreadPoolExecutor$AbortPolicy AbortPolicy InnerClasses B w B ¸ (java/util/concurrent/locks/ReentrantLock 9 : ¹ º ; < = < > ? » w A ? 7 8 java/lang/StringBuilder ][BlockingThreadPoolExecutor submit] 线ç¨æ± 满äºï¼æ æ³æ§è¡å½åä»»å¡, maxTaskCount: ¼ ½ ¼ ¾ , activeTaskCount: ¿ À Á Â Ã Ä Å w java/lang/InterruptedException java/lang/RuntimeException 线ç¨æ± 被ä¸æ... B Ã Æ w Q R Q[BlockingThreadPoolExecutor submit] 线ç¨æ± æ·»å äºä¸ä¸ªä»»å¡, maxTaskCount: Ç Ã Q ` Q f j k @ ? X[BlockingThreadPoolExecutor beforeExecute] =======> maxTaskCount:{}, currentTaskCount:{} È É Ê Â Ë Ì Í w d[BlockingThreadPoolExecutor beforeExecute] æä¸ä¸ªçº¿ç¨æ± ä»»å¡å¼å§æ£å¼æ§è¡, maxTaskCount: , currentTaskCount: o p [[BlockingThreadPoolExecutor afterExecute] å®æäºä¸ä¸ªçº¿ç¨æ± ä»»å¡, currentTaskCount: Î w Ï Ð Ñ Ò s ;com/yami/trading/common/executor/BlockingThreadPoolExecutor Ó Ô Õ 'java/util/concurrent/ThreadPoolExecutor java/lang/Throwable java/util/concurrent/TimeUnit SECONDS x(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Ljava/util/concurrent/RejectedExecutionHandler;)V newCondition (()Ljava/util/concurrent/locks/Condition; lock append -(Ljava/lang/String;)Ljava/lang/StringBuilder; (I)Ljava/lang/StringBuilder; toString ()Ljava/lang/String; org/slf4j/Logger warn (Ljava/lang/String;)V $java/util/concurrent/locks/Condition await unlock info java/lang/Integer valueOf (I)Ljava/lang/Integer; 9(Ljava/lang/String;Ljava/lang/Object;Ljava/lang/Object;)V java/lang/Thread interrupt signalAll getQueue &()Ljava/util/concurrent/BlockingQueue; "java/util/concurrent/BlockingQueue size org/slf4j/LoggerFactory getLogger %(Ljava/lang/Class;)Lorg/slf4j/Logger; ! 4 6 7 8 9 : ; < = < > ? B @ ? B A ?
|
B C D E * ² · ± E
|
F G H I ? B J D § A* !» Y· » Y· · *»
|
Y· µ **´ ¶ µ **´ ¶ µ * `µ ± E # . 9 @ F 4 A G H A K ? A L ? A M N A O P Q R D Z £*´ ¶ *´ *´ £ D² » Y· ¶ *´ ¶ ¶ *´ ¶ ¶ ¹ *´ ¹ §ÿÂM» Y · ¿*´ ¶ !§ N*´ ¶ !-¿*+· "M*Y´ `µ ² » Y· #¶ *´ ¶ ¶ *´ ¶ ¶ ¹ $ ,° E H S ] E > " % ' < ( E + H ) I * S . Z / ] . e / g 2 m 3 w 4 ¡ 5 F * I
|
S T £ G H £ U V m 6 W X Y m 6 W Z [ ÷ @ \
|
I ] ^ _ Q ` D y ¦*´ ¶ *´ *´ £ D² » Y· ¶ *´ ¶ ¶ *´ ¶ ¶ ¹ *´ ¹ §ÿÂN» Y · ¿*´ ¶ !§ :*´ ¶ !¿*+,· %N*Y´ `µ ² » Y· #¶ *´ ¶ ¶ *´ ¶ ¶ ¹ $ -° E H S ] ] _ ] E > : = ? < @ E C H A I B S F Z G ] F f G i I p J z K ¤ L F 4 I
|
S T ¦ G H ¦ U V ¦ a b p 6 W X Y ¦ a c p 6 W d [ ÷ @ \
|
I ] ^ e Q f D d £*´ ¶ *´ *´ £ D² » Y· ¶ *´ ¶ ¶ *´ ¶ ¶ ¹ *´ ¹ §ÿÂM» Y · ¿*´ ¶ !§ N*´ ¶ !-¿*+· &M*Y´ `µ ² » Y· #¶ *´ ¶ ¶ *´ ¶ ¶ ¹ $ ,° E H S ] E > Q T V < W E Z H X I Y S ] Z ^ ] ] e ^ g ` m a w b ¡ c F * I
|
S T £ G H £ U g m 6 W X Y £ U h m 6 W d [ ÷ @ \
|
I ] ^ i j k D N *+,· '*´ ¶ *´ *´ (`£ /² )*´ ¸ **´ (¸ *¹ + *´ ¹ §ÿÒN+¶ ,§ÿÊ*Y´ (`µ (² » Y· -¶ *´ ¶ ¶ *´ ¶ .¶ *´ (¶ ¶ ¹ $ *´ ¶ !§ :*´ ¶ !¿± ; > E B o p t v 2 w ; z > x ? y C z F | P } F * ? S T G H l m n V [ p \÷ I ] o p D ó r*+,· /*´ ¶ *Y´ (dµ (*Y´ dµ ² » Y· 0¶ *´ (¶ ¶ *´ ¶ ¶ ¹ $ *´ ¹ 1 *´ ¹ 1 *´ ¶ !§ N*´ ¶ !-¿± ] g E 2 ! K T ] d g o q F r G H r n V r l q [ ÷ g ] r s D / *´ (¬ E ¤ F G H t s D -*´ ¶ *´ (<*¶ 2¹ 3 `<=*´ ¶ ! ¬N*´ ¶ !-¿ # E " ¯ ° ² ´ ! ² # ´ + µ F u ? - G H [ c ] v w D ! 4¸ 5³ ± E x y
|
6
|
