public class com.oracle.graal.python.runtime.AsyncHandler
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: com.oracle.graal.python.runtime.AsyncHandler
super_class: java.lang.Object
{
private final java.util.concurrent.ScheduledExecutorService executorService;
descriptor: Ljava/util/concurrent/ScheduledExecutorService;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private final java.lang.ref.WeakReference<com.oracle.graal.python.runtime.PythonContext> context;
descriptor: Ljava/lang/ref/WeakReference;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/lang/ref/WeakReference<Lcom/oracle/graal/python/runtime/PythonContext;>;
private final java.util.concurrent.ConcurrentLinkedQueue<com.oracle.graal.python.runtime.AsyncHandler$AsyncAction> scheduledActions;
descriptor: Ljava/util/concurrent/ConcurrentLinkedQueue;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/concurrent/ConcurrentLinkedQueue<Lcom/oracle/graal/python/runtime/AsyncHandler$AsyncAction;>;
private volatile boolean hasScheduledAction;
descriptor: Z
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private final java.util.concurrent.locks.Lock executingScheduledActions;
descriptor: Ljava/util/concurrent/locks/Lock;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
private static final int ASYNC_ACTION_DELAY;
descriptor: I
flags: (0x001a) ACC_PRIVATE, ACC_STATIC, ACC_FINAL
ConstantValue: 15
private final com.oracle.truffle.api.RootCallTarget callTarget;
descriptor: Lcom/oracle/truffle/api/RootCallTarget;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
void <init>(com.oracle.graal.python.runtime.PythonContext);
descriptor: (Lcom/oracle/graal/python/runtime/PythonContext;)V
flags: (0x0000)
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
iconst_4
new com.oracle.graal.python.runtime.AsyncHandler$1
dup
aload 0
invokespecial com.oracle.graal.python.runtime.AsyncHandler$1.<init>:(Lcom/oracle/graal/python/runtime/AsyncHandler;)V
invokestatic java.util.concurrent.Executors.newScheduledThreadPool:(ILjava/util/concurrent/ThreadFactory;)Ljava/util/concurrent/ScheduledExecutorService;
putfield com.oracle.graal.python.runtime.AsyncHandler.executorService:Ljava/util/concurrent/ScheduledExecutorService;
2: aload 0
new java.util.concurrent.ConcurrentLinkedQueue
dup
invokespecial java.util.concurrent.ConcurrentLinkedQueue.<init>:()V
putfield com.oracle.graal.python.runtime.AsyncHandler.scheduledActions:Ljava/util/concurrent/ConcurrentLinkedQueue;
3: aload 0
iconst_0
putfield com.oracle.graal.python.runtime.AsyncHandler.hasScheduledAction:Z
4: aload 0
new java.util.concurrent.locks.ReentrantLock
dup
invokespecial java.util.concurrent.locks.ReentrantLock.<init>:()V
putfield com.oracle.graal.python.runtime.AsyncHandler.executingScheduledActions:Ljava/util/concurrent/locks/Lock;
5: aload 0
new java.lang.ref.WeakReference
dup
aload 1
invokespecial java.lang.ref.WeakReference.<init>:(Ljava/lang/Object;)V
putfield com.oracle.graal.python.runtime.AsyncHandler.context:Ljava/lang/ref/WeakReference;
6: aload 0
new com.oracle.graal.python.runtime.AsyncHandler$CallRootNode
dup
aload 1
invokevirtual com.oracle.graal.python.runtime.PythonContext.getLanguage:()Lcom/oracle/graal/python/PythonLanguage;
invokespecial com.oracle.graal.python.runtime.AsyncHandler$CallRootNode.<init>:(Lcom/oracle/truffle/api/TruffleLanguage;)V
invokestatic com.oracle.graal.python.util.PythonUtils.getOrCreateCallTarget:(Lcom/oracle/truffle/api/nodes/RootNode;)Lcom/oracle/truffle/api/RootCallTarget;
putfield com.oracle.graal.python.runtime.AsyncHandler.callTarget:Lcom/oracle/truffle/api/RootCallTarget;
7: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lcom/oracle/graal/python/runtime/AsyncHandler;
0 8 1 context Lcom/oracle/graal/python/runtime/PythonContext;
MethodParameters:
Name Flags
context
void registerAction(com.oracle.graal.python.util.Supplier<com.oracle.graal.python.runtime.AsyncHandler$AsyncAction>);
descriptor: (Lcom/oracle/graal/python/util/Supplier;)V
flags: (0x0000)
Code:
stack=7, locals=2, args_size=2
start local 0 start local 1 0: invokestatic com.oracle.truffle.api.CompilerAsserts.neverPartOfCompilation:()V
1: invokestatic com.oracle.graal.python.PythonLanguage.getContext:()Lcom/oracle/graal/python/runtime/PythonContext;
getstatic com.oracle.graal.python.runtime.PythonOptions.NoAsyncActions:Lorg/graalvm/options/OptionKey;
invokevirtual com.oracle.graal.python.runtime.PythonContext.getOption:(Lorg/graalvm/options/OptionKey;)Ljava/lang/Object;
checkcast java.lang.Boolean
invokevirtual java.lang.Boolean.booleanValue:()Z
ifeq 3
2: return
3: StackMap locals:
StackMap stack:
aload 0
getfield com.oracle.graal.python.runtime.AsyncHandler.executorService:Ljava/util/concurrent/ScheduledExecutorService;
new com.oracle.graal.python.runtime.AsyncHandler$AsyncRunnable
dup
aload 0
aload 1
invokespecial com.oracle.graal.python.runtime.AsyncHandler$AsyncRunnable.<init>:(Lcom/oracle/graal/python/runtime/AsyncHandler;Lcom/oracle/graal/python/util/Supplier;)V
ldc 15
ldc 15
getstatic java.util.concurrent.TimeUnit.MILLISECONDS:Ljava/util/concurrent/TimeUnit;
invokeinterface java.util.concurrent.ScheduledExecutorService.scheduleWithFixedDelay:(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
pop
4: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 5 0 this Lcom/oracle/graal/python/runtime/AsyncHandler;
0 5 1 actionSupplier Lcom/oracle/graal/python/util/Supplier<Lcom/oracle/graal/python/runtime/AsyncHandler$AsyncAction;>;
Signature: (Lcom/oracle/graal/python/util/Supplier<Lcom/oracle/graal/python/runtime/AsyncHandler$AsyncAction;>;)V
MethodParameters:
Name Flags
actionSupplier
void triggerAsyncActions(com.oracle.truffle.api.frame.VirtualFrame, com.oracle.truffle.api.profiles.BranchProfile);
descriptor: (Lcom/oracle/truffle/api/frame/VirtualFrame;Lcom/oracle/truffle/api/profiles/BranchProfile;)V
flags: (0x0000)
Code:
stack=3, locals=4, args_size=3
start local 0 start local 1 start local 2 0: ldc 1.0E-4
aload 0
getfield com.oracle.graal.python.runtime.AsyncHandler.hasScheduledAction:Z
invokestatic com.oracle.truffle.api.CompilerDirectives.injectBranchProbability:(DZ)Z
ifeq 10
1: aload 2
invokevirtual com.oracle.truffle.api.profiles.BranchProfile.enter:()V
2: aload 1
aload 0
getfield com.oracle.graal.python.runtime.AsyncHandler.context:Ljava/lang/ref/WeakReference;
invokevirtual java.lang.ref.WeakReference.get:()Ljava/lang/Object;
checkcast com.oracle.graal.python.runtime.PythonContext
aconst_null
invokestatic com.oracle.graal.python.runtime.ExecutionContext$IndirectCallContext.enter:(Lcom/oracle/truffle/api/frame/VirtualFrame;Lcom/oracle/graal/python/runtime/PythonContext;Lcom/oracle/graal/python/nodes/IndirectCallNode;)Ljava/lang/Object;
pop
3: invokestatic com.oracle.truffle.api.CompilerDirectives.transferToInterpreter:()V
4: aload 0
invokevirtual com.oracle.graal.python.runtime.AsyncHandler.processAsyncActions:()V
5: goto 9
StackMap locals:
StackMap stack: java.lang.Throwable
6: astore 3
7: aload 1
aload 0
getfield com.oracle.graal.python.runtime.AsyncHandler.context:Ljava/lang/ref/WeakReference;
invokevirtual java.lang.ref.WeakReference.get:()Ljava/lang/Object;
checkcast com.oracle.graal.python.runtime.PythonContext
aconst_null
invokestatic com.oracle.graal.python.runtime.ExecutionContext$IndirectCallContext.exit:(Lcom/oracle/truffle/api/frame/VirtualFrame;Lcom/oracle/graal/python/runtime/PythonContext;Ljava/lang/Object;)V
8: aload 3
athrow
9: StackMap locals:
StackMap stack:
aload 1
aload 0
getfield com.oracle.graal.python.runtime.AsyncHandler.context:Ljava/lang/ref/WeakReference;
invokevirtual java.lang.ref.WeakReference.get:()Ljava/lang/Object;
checkcast com.oracle.graal.python.runtime.PythonContext
aconst_null
invokestatic com.oracle.graal.python.runtime.ExecutionContext$IndirectCallContext.exit:(Lcom/oracle/truffle/api/frame/VirtualFrame;Lcom/oracle/graal/python/runtime/PythonContext;Ljava/lang/Object;)V
10: StackMap locals:
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 11 0 this Lcom/oracle/graal/python/runtime/AsyncHandler;
0 11 1 frame Lcom/oracle/truffle/api/frame/VirtualFrame;
0 11 2 actionProfile Lcom/oracle/truffle/api/profiles/BranchProfile;
Exception table:
from to target type
3 6 6 any
MethodParameters:
Name Flags
frame
actionProfile
private void processAsyncActions();
descriptor: ()V
flags: (0x0002) ACC_PRIVATE
Code:
stack=2, locals=5, args_size=1
start local 0 0: aload 0
getfield com.oracle.graal.python.runtime.AsyncHandler.context:Ljava/lang/ref/WeakReference;
invokevirtual java.lang.ref.WeakReference.get:()Ljava/lang/Object;
checkcast com.oracle.graal.python.runtime.PythonContext
astore 1
start local 1 1: aload 1
ifnonnull 3
2: return
3: StackMap locals: com.oracle.graal.python.runtime.PythonContext
StackMap stack:
aload 0
getfield com.oracle.graal.python.runtime.AsyncHandler.executingScheduledActions:Ljava/util/concurrent/locks/Lock;
invokeinterface java.util.concurrent.locks.Lock.tryLock:()Z
ifeq 15
4: aload 0
iconst_0
putfield com.oracle.graal.python.runtime.AsyncHandler.hasScheduledAction:Z
5: aload 0
getfield com.oracle.graal.python.runtime.AsyncHandler.scheduledActions:Ljava/util/concurrent/ConcurrentLinkedQueue;
astore 2
start local 2 6: goto 8
start local 3 7: StackMap locals: java.util.concurrent.ConcurrentLinkedQueue com.oracle.graal.python.runtime.AsyncHandler$AsyncAction
StackMap stack:
aload 3
aload 1
invokeinterface com.oracle.graal.python.runtime.AsyncHandler$AsyncAction.execute:(Lcom/oracle/graal/python/runtime/PythonContext;)V
end local 3 8: StackMap locals:
StackMap stack:
aload 2
invokevirtual java.util.concurrent.ConcurrentLinkedQueue.poll:()Ljava/lang/Object;
checkcast com.oracle.graal.python.runtime.AsyncHandler$AsyncAction
dup
astore 3
start local 3 9: ifnonnull 7
end local 3 end local 2 10: goto 14
StackMap locals: com.oracle.graal.python.runtime.AsyncHandler com.oracle.graal.python.runtime.PythonContext
StackMap stack: java.lang.Throwable
11: astore 4
12: aload 0
getfield com.oracle.graal.python.runtime.AsyncHandler.executingScheduledActions:Ljava/util/concurrent/locks/Lock;
invokeinterface java.util.concurrent.locks.Lock.unlock:()V
13: aload 4
athrow
14: StackMap locals:
StackMap stack:
aload 0
getfield com.oracle.graal.python.runtime.AsyncHandler.executingScheduledActions:Ljava/util/concurrent/locks/Lock;
invokeinterface java.util.concurrent.locks.Lock.unlock:()V
15: StackMap locals:
StackMap stack:
return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 16 0 this Lcom/oracle/graal/python/runtime/AsyncHandler;
1 16 1 ctx Lcom/oracle/graal/python/runtime/PythonContext;
6 10 2 actions Ljava/util/concurrent/ConcurrentLinkedQueue<Lcom/oracle/graal/python/runtime/AsyncHandler$AsyncAction;>;
7 8 3 action Lcom/oracle/graal/python/runtime/AsyncHandler$AsyncAction;
9 10 3 action Lcom/oracle/graal/python/runtime/AsyncHandler$AsyncAction;
Exception table:
from to target type
5 11 11 any
public void shutdown();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=1, locals=1, args_size=1
start local 0 0: aload 0
getfield com.oracle.graal.python.runtime.AsyncHandler.executorService:Ljava/util/concurrent/ScheduledExecutorService;
invokeinterface java.util.concurrent.ScheduledExecutorService.shutdownNow:()Ljava/util/List;
pop
1: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lcom/oracle/graal/python/runtime/AsyncHandler;
}
SourceFile: "AsyncHandler.java"
NestMembers:
com.oracle.graal.python.runtime.AsyncHandler$1 com.oracle.graal.python.runtime.AsyncHandler$AsyncAction com.oracle.graal.python.runtime.AsyncHandler$AsyncPythonAction com.oracle.graal.python.runtime.AsyncHandler$AsyncRunnable com.oracle.graal.python.runtime.AsyncHandler$CallRootNode com.oracle.graal.python.runtime.AsyncHandler$SharedFinalizer com.oracle.graal.python.runtime.AsyncHandler$SharedFinalizer$FinalizableReference com.oracle.graal.python.runtime.AsyncHandler$SharedFinalizer$SharedFinalizerErrorCallback
InnerClasses:
com.oracle.graal.python.runtime.AsyncHandler$1
public abstract AsyncAction = com.oracle.graal.python.runtime.AsyncHandler$AsyncAction of com.oracle.graal.python.runtime.AsyncHandler
public abstract AsyncPythonAction = com.oracle.graal.python.runtime.AsyncHandler$AsyncPythonAction of com.oracle.graal.python.runtime.AsyncHandler
private AsyncRunnable = com.oracle.graal.python.runtime.AsyncHandler$AsyncRunnable of com.oracle.graal.python.runtime.AsyncHandler
private CallRootNode = com.oracle.graal.python.runtime.AsyncHandler$CallRootNode of com.oracle.graal.python.runtime.AsyncHandler
public SharedFinalizer = com.oracle.graal.python.runtime.AsyncHandler$SharedFinalizer of com.oracle.graal.python.runtime.AsyncHandler
public abstract IndirectCallContext = com.oracle.graal.python.runtime.ExecutionContext$IndirectCallContext of com.oracle.graal.python.runtime.ExecutionContext