public class io.vertx.core.shareddata.impl.LocalAsyncLocks
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: io.vertx.core.shareddata.impl.LocalAsyncLocks
super_class: java.lang.Object
{
private final java.util.concurrent.ConcurrentMap<java.lang.String, java.util.List<io.vertx.core.shareddata.impl.LocalAsyncLocks$LockWaiter>> waitersMap;
descriptor: Ljava/util/concurrent/ConcurrentMap;
flags: (0x0012) ACC_PRIVATE, ACC_FINAL
Signature: Ljava/util/concurrent/ConcurrentMap<Ljava/lang/String;Ljava/util/List<Lio/vertx/core/shareddata/impl/LocalAsyncLocks$LockWaiter;>;>;
public void <init>();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=1, args_size=1
start local 0 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.util.concurrent.ConcurrentHashMap
dup
invokespecial java.util.concurrent.ConcurrentHashMap.<init>:()V
putfield io.vertx.core.shareddata.impl.LocalAsyncLocks.waitersMap:Ljava/util/concurrent/ConcurrentMap;
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lio/vertx/core/shareddata/impl/LocalAsyncLocks;
public io.vertx.core.Future<io.vertx.core.shareddata.Lock> acquire(io.vertx.core.impl.ContextInternal, java.lang.String, long);
descriptor: (Lio/vertx/core/impl/ContextInternal;Ljava/lang/String;J)Lio/vertx/core/Future;
flags: (0x0001) ACC_PUBLIC
Code:
stack=8, locals=8, args_size=4
start local 0 start local 1 start local 2 start local 3 0: aload 1
invokeinterface io.vertx.core.impl.ContextInternal.promise:()Lio/vertx/core/impl/future/PromiseInternal;
astore 5
start local 5 1: new io.vertx.core.shareddata.impl.LocalAsyncLocks$LockWaiter
dup
aload 0
aload 1
aload 2
lload 3
aload 5
invokespecial io.vertx.core.shareddata.impl.LocalAsyncLocks$LockWaiter.<init>:(Lio/vertx/core/shareddata/impl/LocalAsyncLocks;Lio/vertx/core/impl/ContextInternal;Ljava/lang/String;JLio/vertx/core/Promise;)V
astore 6
start local 6 2: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncLocks.waitersMap:Ljava/util/concurrent/ConcurrentMap;
aload 2
aload 6
invokedynamic apply(Lio/vertx/core/shareddata/impl/LocalAsyncLocks$LockWaiter;)Ljava/util/function/BiFunction;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.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;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/core/shareddata/impl/LocalAsyncLocks.lambda$0(Lio/vertx/core/shareddata/impl/LocalAsyncLocks$LockWaiter;Ljava/lang/String;Ljava/util/List;)Ljava/util/List; (6)
(Ljava/lang/String;Ljava/util/List;)Ljava/util/List;
invokeinterface java.util.concurrent.ConcurrentMap.compute:(Ljava/lang/Object;Ljava/util/function/BiFunction;)Ljava/lang/Object;
checkcast java.util.List
astore 7
start local 7 3: aload 7
invokeinterface java.util.List.size:()I
iconst_1
if_icmpne 5
4: aload 7
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast io.vertx.core.shareddata.impl.LocalAsyncLocks$LockWaiter
invokevirtual io.vertx.core.shareddata.impl.LocalAsyncLocks$LockWaiter.acquireLock:()V
5: StackMap locals: io.vertx.core.Promise io.vertx.core.shareddata.impl.LocalAsyncLocks$LockWaiter java.util.List
StackMap stack:
aload 5
invokeinterface io.vertx.core.Promise.future:()Lio/vertx/core/Future;
areturn
end local 7 end local 6 end local 5 end local 3 end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 6 0 this Lio/vertx/core/shareddata/impl/LocalAsyncLocks;
0 6 1 context Lio/vertx/core/impl/ContextInternal;
0 6 2 name Ljava/lang/String;
0 6 3 timeout J
1 6 5 promise Lio/vertx/core/Promise<Lio/vertx/core/shareddata/Lock;>;
2 6 6 lockWaiter Lio/vertx/core/shareddata/impl/LocalAsyncLocks$LockWaiter;
3 6 7 waiters Ljava/util/List<Lio/vertx/core/shareddata/impl/LocalAsyncLocks$LockWaiter;>;
Signature: (Lio/vertx/core/impl/ContextInternal;Ljava/lang/String;J)Lio/vertx/core/Future<Lio/vertx/core/shareddata/Lock;>;
MethodParameters:
Name Flags
context
name
timeout
private void nextWaiter(java.lang.String);
descriptor: (Ljava/lang/String;)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=3, locals=3, args_size=2
start local 0 start local 1 0: aload 0
getfield io.vertx.core.shareddata.impl.LocalAsyncLocks.waitersMap:Ljava/util/concurrent/ConcurrentMap;
aload 1
invokedynamic apply()Ljava/util/function/BiFunction;
Bootstrap: invokestatic java.lang.invoke.LambdaMetafactory.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;
Method arguments:
(Ljava/lang/Object;Ljava/lang/Object;)Ljava/lang/Object;
io/vertx/core/shareddata/impl/LocalAsyncLocks.lambda$1(Ljava/lang/String;Ljava/util/List;)Ljava/util/List; (6)
(Ljava/lang/String;Ljava/util/List;)Ljava/util/List;
invokeinterface java.util.concurrent.ConcurrentMap.compute:(Ljava/lang/Object;Ljava/util/function/BiFunction;)Ljava/lang/Object;
checkcast java.util.List
astore 2
start local 2 1: aload 2
ifnull 3
2: aload 2
iconst_0
invokeinterface java.util.List.get:(I)Ljava/lang/Object;
checkcast io.vertx.core.shareddata.impl.LocalAsyncLocks$LockWaiter
invokevirtual io.vertx.core.shareddata.impl.LocalAsyncLocks$LockWaiter.acquireLock:()V
3: StackMap locals: java.util.List
StackMap stack:
return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lio/vertx/core/shareddata/impl/LocalAsyncLocks;
0 4 1 lockName Ljava/lang/String;
1 4 2 waiters Ljava/util/List<Lio/vertx/core/shareddata/impl/LocalAsyncLocks$LockWaiter;>;
MethodParameters:
Name Flags
lockName
private static java.util.List lambda$0(io.vertx.core.shareddata.impl.LocalAsyncLocks$LockWaiter, java.lang.String, java.util.List);
descriptor: (Lio/vertx/core/shareddata/impl/LocalAsyncLocks$LockWaiter;Ljava/lang/String;Ljava/util/List;)Ljava/util/List;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=4, locals=4, args_size=3
start local 1 start local 2 0: aload 2
ifnull 4
1: new java.util.ArrayList
dup
aload 2
invokeinterface java.util.List.size:()I
iconst_1
iadd
invokespecial java.util.ArrayList.<init>:(I)V
astore 3
start local 3 2: aload 3
aload 2
invokeinterface java.util.List.addAll:(Ljava/util/Collection;)Z
pop
3: goto 5
end local 3 4: StackMap locals:
StackMap stack:
new java.util.ArrayList
dup
iconst_1
invokespecial java.util.ArrayList.<init>:(I)V
astore 3
start local 3 5: StackMap locals: java.util.List
StackMap stack:
aload 3
aload 0
invokeinterface java.util.List.add:(Ljava/lang/Object;)Z
pop
6: aload 3
areturn
end local 3 end local 2 end local 1 LocalVariableTable:
Start End Slot Name Signature
0 7 1 s Ljava/lang/String;
0 7 2 list Ljava/util/List<Lio/vertx/core/shareddata/impl/LocalAsyncLocks$LockWaiter;>;
2 4 3 result Ljava/util/List<Lio/vertx/core/shareddata/impl/LocalAsyncLocks$LockWaiter;>;
5 7 3 result Ljava/util/List<Lio/vertx/core/shareddata/impl/LocalAsyncLocks$LockWaiter;>;
private static java.util.List lambda$1(java.lang.String, java.util.List);
descriptor: (Ljava/lang/String;Ljava/util/List;)Ljava/util/List;
flags: (0x100a) ACC_PRIVATE, ACC_STATIC, ACC_SYNTHETIC
Code:
stack=5, locals=2, args_size=2
start local 0 start local 1 0: aload 1
ifnull 1
aload 1
invokeinterface java.util.List.size:()I
iconst_1
if_icmpne 2
StackMap locals:
StackMap stack:
1: aconst_null
goto 3
StackMap locals:
StackMap stack:
2: new java.util.ArrayList
dup
aload 1
iconst_1
aload 1
invokeinterface java.util.List.size:()I
invokeinterface java.util.List.subList:(II)Ljava/util/List;
invokespecial java.util.ArrayList.<init>:(Ljava/util/Collection;)V
StackMap locals:
StackMap stack: java.util.ArrayList
3: areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 s Ljava/lang/String;
0 4 1 list Ljava/util/List<Lio/vertx/core/shareddata/impl/LocalAsyncLocks$LockWaiter;>;
}
SourceFile: "LocalAsyncLocks.java"
NestMembers:
io.vertx.core.shareddata.impl.LocalAsyncLocks$AsyncLock io.vertx.core.shareddata.impl.LocalAsyncLocks$LockWaiter
InnerClasses:
private AsyncLock = io.vertx.core.shareddata.impl.LocalAsyncLocks$AsyncLock of io.vertx.core.shareddata.impl.LocalAsyncLocks
private LockWaiter = io.vertx.core.shareddata.impl.LocalAsyncLocks$LockWaiter of io.vertx.core.shareddata.impl.LocalAsyncLocks
public final Lookup = java.lang.invoke.MethodHandles$Lookup of java.lang.invoke.MethodHandles