public class org.h2.store.WriterThread implements java.lang.Runnable
minor version: 0
major version: 59
flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
this_class: org.h2.store.WriterThread
super_class: java.lang.Object
{
private volatile java.lang.ref.WeakReference<org.h2.engine.Database> databaseRef;
descriptor: Ljava/lang/ref/WeakReference;
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
Signature: Ljava/lang/ref/WeakReference<Lorg/h2/engine/Database;>;
private int writeDelay;
descriptor: I
flags: (0x0002) ACC_PRIVATE
private java.lang.Thread thread;
descriptor: Ljava/lang/Thread;
flags: (0x0002) ACC_PRIVATE
private volatile boolean stop;
descriptor: Z
flags: (0x0042) ACC_PRIVATE, ACC_VOLATILE
private void <init>(org.h2.engine.Database, int);
descriptor: (Lorg/h2/engine/Database;I)V
flags: (0x0002) ACC_PRIVATE
Code:
stack=4, locals=3, args_size=3
start local 0 start local 1 start local 2 0: aload 0
invokespecial java.lang.Object.<init>:()V
1: aload 0
new java.lang.ref.WeakReference
dup
aload 1
invokespecial java.lang.ref.WeakReference.<init>:(Ljava/lang/Object;)V
putfield org.h2.store.WriterThread.databaseRef:Ljava/lang/ref/WeakReference;
2: aload 0
iload 2
putfield org.h2.store.WriterThread.writeDelay:I
3: return
end local 2 end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 4 0 this Lorg/h2/store/WriterThread;
0 4 1 database Lorg/h2/engine/Database;
0 4 2 writeDelay I
MethodParameters:
Name Flags
database
writeDelay
public void setWriteDelay(int);
descriptor: (I)V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=2
start local 0 start local 1 0: aload 0
iload 1
putfield org.h2.store.WriterThread.writeDelay:I
1: return
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 2 0 this Lorg/h2/store/WriterThread;
0 2 1 writeDelay I
MethodParameters:
Name Flags
writeDelay
public static org.h2.store.WriterThread create(org.h2.engine.Database, int);
descriptor: (Lorg/h2/engine/Database;I)Lorg/h2/store/WriterThread;
flags: (0x0009) ACC_PUBLIC, ACC_STATIC
Code:
stack=7, locals=3, args_size=2
start local 0 start local 1 0: new org.h2.store.WriterThread
dup
aload 0
iload 1
invokespecial org.h2.store.WriterThread.<init>:(Lorg/h2/engine/Database;I)V
astore 2
start local 2 1: aload 2
new java.lang.Thread
dup
aload 2
new java.lang.StringBuilder
dup
ldc "H2 Log Writer "
invokespecial java.lang.StringBuilder.<init>:(Ljava/lang/String;)V
aload 0
invokevirtual org.h2.engine.Database.getShortName:()Ljava/lang/String;
invokevirtual java.lang.StringBuilder.append:(Ljava/lang/String;)Ljava/lang/StringBuilder;
invokevirtual java.lang.StringBuilder.toString:()Ljava/lang/String;
invokespecial java.lang.Thread.<init>:(Ljava/lang/Runnable;Ljava/lang/String;)V
putfield org.h2.store.WriterThread.thread:Ljava/lang/Thread;
2: aload 2
getfield org.h2.store.WriterThread.thread:Ljava/lang/Thread;
invokestatic org.h2.Driver.setThreadContextClassLoader:(Ljava/lang/Thread;)V
3: aload 2
getfield org.h2.store.WriterThread.thread:Ljava/lang/Thread;
iconst_1
invokevirtual java.lang.Thread.setDaemon:(Z)V
4: aload 2
5: areturn
end local 2 6: StackMap locals:
StackMap stack: java.security.AccessControlException
pop
7: aconst_null
areturn
end local 1 end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 database Lorg/h2/engine/Database;
0 8 1 writeDelay I
1 6 2 writer Lorg/h2/store/WriterThread;
Exception table:
from to target type
0 5 6 Class java.security.AccessControlException
MethodParameters:
Name Flags
database
writeDelay
public void run();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=3, locals=5, args_size=1
start local 0 0: goto 28
1: StackMap locals:
StackMap stack:
aload 0
getfield org.h2.store.WriterThread.databaseRef:Ljava/lang/ref/WeakReference;
invokevirtual java.lang.ref.WeakReference.get:()Ljava/lang/Object;
checkcast org.h2.engine.Database
astore 1
start local 1 2: aload 1
ifnonnull 4
3: goto 29
4: StackMap locals: org.h2.engine.Database
StackMap stack:
aload 0
getfield org.h2.store.WriterThread.writeDelay:I
istore 2
start local 2 5: aload 1
invokevirtual org.h2.engine.Database.isFileLockSerialized:()Z
ifeq 9
6: iconst_5
istore 2
7: aload 1
invokevirtual org.h2.engine.Database.checkpointIfRequired:()V
8: goto 15
9: StackMap locals: int
StackMap stack:
aload 1
invokevirtual org.h2.engine.Database.flush:()V
10: goto 15
StackMap locals:
StackMap stack: java.lang.Exception
11: astore 3
start local 3 12: aload 1
invokevirtual org.h2.engine.Database.getTraceSystem:()Lorg/h2/message/TraceSystem;
astore 4
start local 4 13: aload 4
ifnull 15
14: aload 4
iconst_2
invokevirtual org.h2.message.TraceSystem.getTrace:(I)Lorg/h2/message/Trace;
aload 3
ldc "flush"
invokevirtual org.h2.message.Trace.error:(Ljava/lang/Throwable;Ljava/lang/String;)V
end local 4 end local 3 15: StackMap locals:
StackMap stack:
iload 2
iconst_5
invokestatic java.lang.Math.max:(II)I
istore 2
16: aload 0
dup
astore 3
monitorenter
17: goto 23
18: StackMap locals: org.h2.store.WriterThread
StackMap stack:
iload 2
bipush 100
invokestatic java.lang.Math.min:(II)I
istore 4
start local 4 19: aload 0
iload 4
i2l
invokevirtual java.lang.Object.wait:(J)V
20: goto 22
StackMap locals: org.h2.store.WriterThread org.h2.engine.Database int org.h2.store.WriterThread int
StackMap stack: java.lang.InterruptedException
21: pop
22: StackMap locals:
StackMap stack:
iload 2
iload 4
isub
istore 2
end local 4 23: StackMap locals:
StackMap stack:
aload 0
getfield org.h2.store.WriterThread.stop:Z
ifne 24
iload 2
ifgt 18
24: StackMap locals:
StackMap stack:
aload 3
monitorexit
25: goto 28
StackMap locals:
StackMap stack: java.lang.Throwable
26: aload 3
monitorexit
27: athrow
end local 2 end local 1 28: StackMap locals:
StackMap stack:
aload 0
getfield org.h2.store.WriterThread.stop:Z
ifeq 1
29: StackMap locals:
StackMap stack:
aload 0
aconst_null
putfield org.h2.store.WriterThread.databaseRef:Ljava/lang/ref/WeakReference;
30: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 31 0 this Lorg/h2/store/WriterThread;
2 28 1 database Lorg/h2/engine/Database;
5 28 2 wait I
12 15 3 e Ljava/lang/Exception;
13 15 4 traceSystem Lorg/h2/message/TraceSystem;
19 23 4 w I
Exception table:
from to target type
5 10 11 Class java.lang.Exception
19 20 21 Class java.lang.InterruptedException
17 25 26 any
26 27 26 any
public void stopThread();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=2, args_size=1
start local 0 0: aload 0
iconst_1
putfield org.h2.store.WriterThread.stop:Z
1: aload 0
dup
astore 1
monitorenter
2: aload 0
invokevirtual java.lang.Object.notify:()V
3: aload 1
monitorexit
4: goto 7
StackMap locals: org.h2.store.WriterThread org.h2.store.WriterThread
StackMap stack: java.lang.Throwable
5: aload 1
monitorexit
6: athrow
7: StackMap locals:
StackMap stack:
return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 8 0 this Lorg/h2/store/WriterThread;
Exception table:
from to target type
2 4 5 any
5 6 5 any
public void startThread();
descriptor: ()V
flags: (0x0001) ACC_PUBLIC
Code:
stack=2, locals=1, args_size=1
start local 0 0: aload 0
getfield org.h2.store.WriterThread.thread:Ljava/lang/Thread;
invokevirtual java.lang.Thread.start:()V
1: aload 0
aconst_null
putfield org.h2.store.WriterThread.thread:Ljava/lang/Thread;
2: return
end local 0 LocalVariableTable:
Start End Slot Name Signature
0 3 0 this Lorg/h2/store/WriterThread;
}
SourceFile: "WriterThread.java"