oying消息中心message业务1.0

leomon

2025-05-14 3387f6754a07694dda1307849a3ab6fe8a24d7c5

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
Êþº¾4•
#O    "P    "Q    "R    "SXY    Z[\
    ]^
O
ab
O
c
d
e
fg
h
ijk
Ol
mn
]
o
p
q
rstu
corePoolSize

I
maxPoolSize
keepAliveSeconds
 queueCapacity
<init>
()V
Code
LineNumberTable
LocalVariableTable
this
 Lcom/oying/config/AsyncExecutor;
setCorePoolSize
(I)V
MethodParameters
RuntimeVisibleAnnotations
4Lorg/springframework/beans/factory/annotation/Value;
value
${task.pool.core-pool-size}
setMaxPoolSize
${task.pool.max-pool-size}
setKeepAliveSeconds
${task.pool.keep-alive-seconds}
setQueueCapacity
${task.pool.queue-capacity}
getAsyncExecutor
!()Ljava/util/concurrent/Executor;
factory
$Ljava/util/concurrent/ThreadFactory;
    taskAsync
D()Lorg/springframework/scheduling/concurrent/ThreadPoolTaskExecutor;
executor
BLorg/springframework/scheduling/concurrent/ThreadPoolTaskExecutor;
-Lorg/springframework/context/annotation/Bean;
lambda$getAsyncExecutor$0
((Ljava/lang/Runnable;)Ljava/lang/Thread;

r
Ljava/lang/Runnable;

SourceFile
AsyncExecutor.java
7Lorg/springframework/scheduling/annotation/EnableAsync;
6Lorg/springframework/context/annotation/Configuration;*+%&'&(&)&
BootstrapMethodsvHwxy
'java/util/concurrent/ThreadPoolExecutorz{|
'java/util/concurrent/ArrayBlockingQueue*2
8java/util/concurrent/ThreadPoolExecutor$CallerRunsPolicy
CallerRunsPolicy
InnerClasses*}
@org/springframework/scheduling/concurrent/ThreadPoolTaskExecutor1282<2:2
el-task-~€
java/lang/Thread
java/lang/StringBuilder
    el-async-‚ƒ
)java/util/concurrent/atomic/AtomicInteger„…‚†‡ˆ*‰
com/oying/config/AsyncExecutor
java/lang/Object
9org/springframework/scheduling/annotation/AsyncConfigurer
Š‹
"Œ
    newThread
&()Ljava/util/concurrent/ThreadFactory;
java/util/concurrent/TimeUnit
SECONDS
Ljava/util/concurrent/TimeUnit;
œ(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Ljava/util/concurrent/ThreadFactory;Ljava/util/concurrent/RejectedExecutionHandler;)V
setThreadNamePrefix
(Ljava/lang/String;)V
setRejectedExecutionHandler
2(Ljava/util/concurrent/RejectedExecutionHandler;)V
append
-(Ljava/lang/String;)Ljava/lang/StringBuilder;
getAndIncrement
()I
(I)Ljava/lang/StringBuilder;
toString
()Ljava/lang/String;
)(Ljava/lang/Runnable;Ljava/lang/String;)VŽ‘GH
"java/lang/invoke/LambdaMetafactory
metafactory“
Lookup
Ì(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;”
%java/lang/invoke/MethodHandles$Lookup
java/lang/invoke/MethodHandles!"#
$    %&    '&    (&    )&
*+
,/

*·
±-
.
/0
12,=
³±-
 !./0%&
3
%4
5
6s7
82,=
³±-
%&./0'&
3
'4
5
6s9
:2,=
³±-
*+./0(&
3
(4
5
6s;
<2,=
³±-
/0./0)&
3
)4
5
6s=
>?
,e-ºL»Y²²²…²»    Y²·
+»Y·· °-
9;.-/0'@A

BC,1»Y·L+¶+¶+¶+<¶+¶+»Y·¶+°-"GH IJKL$M/N.1/0)DE
4
F
6[
sB
GH,P
&»Y*»Y·¶»Y·¶¶¶ ·!°-
9.
&IJ3
IKL4
MN`_    ’T
UVWV