Edit D:\app\Administrator\product\11.2.0\dbhome_1\ons\lib\oracle\eons\blab\JChannelProvider262Impl.class
?? 1 ? $ k l m n o p q # r s # t u # v w x y z { | } o ~ o # ? ? ? ? k ? ? ? ? ? k ? k ? ? } ? ? ? EonsJGroupsThreadFactory InnerClasses TP_ENABLED Z ConstantValue TP_MIN_THREADS I TP_MAX_THREADS TP_KEEPALIVE_MS ' TP_QUEUE_ENABLED TP_QUEUE_MAX ? TP_REJECT_POLICY /Ljava/util/concurrent/RejectedExecutionHandler; OOB_TP_ENABLED OOB_TP_MIN_THREADS OOB_TP_MAX_THREADS OOB_TP_KEEPALIVE_MS OOB_TP_QUEUE_ENABLED OOB_TP_QUEUE_MAX ? OOB_TP_REJECT_POLICY IO_THREADGROUP Ljava/lang/ThreadGroup; <init> ()V Code LineNumberTable LocalVariableTable this *Loracle/eons/blab/JChannelProvider262Impl; getJChannel *(Ljava/lang/String;)Lorg/jgroups/JChannel; props Ljava/lang/String; channel Lorg/jgroups/JChannel; stack !Lorg/jgroups/stack/ProtocolStack; transport Lorg/jgroups/protocols/TP; executor Ljava/util/concurrent/Executor; jgThreadFactory Lorg/jgroups/util/ThreadFactory; Exceptions ? createExecutor h(ZZIIIILjava/util/concurrent/RejectedExecutionHandler;Ljava/lang/String;)Ljava/util/concurrent/Executor; queue $Ljava/util/concurrent/BlockingQueue; threadFactory tpEnabled tpQueueEnabled tpQueueMax tpMinThreads tpMaxThreads tpKeepaliveMs tpRejectPolicy threadName LocalVariableTypeTable :Ljava/util/concurrent/BlockingQueue<Ljava/lang/Runnable;>; <clinit> SourceFile JChannelProvider262Impl.java B C org/jgroups/JChannel B ? ? ? ? ? ? org/jgroups/protocols/TP 5 6 Incoming Y Z ? ? ? 6 OOB ? ? Aoracle/eons/blab/JChannelProvider262Impl$EonsJGroupsThreadFactory ? ? ? JGroups B ? ? ? ? ? @ A (java/util/concurrent/LinkedBlockingQueue B ? %java/util/concurrent/SynchronousQueue 'java/util/concurrent/ThreadPoolExecutor ? ? ? B ? org/jgroups/util/DirectExecutor 8java/util/concurrent/ThreadPoolExecutor$CallerRunsPolicy CallerRunsPolicy java/lang/ThreadGroup JGroups IO Thread Pools (oracle/eons/blab/JChannelProvider262Impl java/lang/Object !oracle/eons/blab/JChannelProvider org/jgroups/ChannelException (Ljava/lang/String;)V getProtocolStack #()Lorg/jgroups/stack/ProtocolStack; org/jgroups/stack/ProtocolStack getTransport ()Lorg/jgroups/stack/Protocol; setDefaultThreadPool "(Ljava/util/concurrent/Executor;)V setOOBThreadPool org/jgroups/util/Util getGlobalThreadGroup ()Ljava/lang/ThreadGroup; ,(Ljava/lang/ThreadGroup;Ljava/lang/String;)V setThreadFactory #(Lorg/jgroups/util/ThreadFactory;)V setTimerThreadFactory (I)V java/util/concurrent/TimeUnit MILLISECONDS Ljava/util/concurrent/TimeUnit; ?(IIJLjava/util/concurrent/TimeUnit;Ljava/util/concurrent/BlockingQueue;Ljava/util/concurrent/ThreadFactory;Ljava/util/concurrent/RejectedExecutionHandler;)V 0 # $ % ( ) * + , - * + . - * / 0 - * 1 2 ) * + 3 - * 4 5 6 7 ) * + 8 - * + 9 - * / : - * 1 ; ) * <