class org.iq.leveldb.util.Finalizer$FinalizerQueueProcessor extends java.lang.Object implements java.lang.Runnable
{
final org.iq.leveldb.util.Finalizer this$0;
private void <init>(org.iq.leveldb.util.Finalizer)
{
org.iq.leveldb.util.Finalizer v;
org.iq.leveldb.util.Finalizer$FinalizerQueueProcessor v;
v := @this: org.iq.leveldb.util.Finalizer$FinalizerQueueProcessor;
v := @parameter: org.iq.leveldb.util.Finalizer;
v.<org.iq.leveldb.util.Finalizer$FinalizerQueueProcessor: org.iq.leveldb.util.Finalizer this$0> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void run()
{
java.lang.Throwable v, v;
java.util.concurrent.atomic.AtomicBoolean v, v;
java.lang.ref.ReferenceQueue v;
org.iq.leveldb.util.Finalizer v, v, v, v, v, v, v, v;
org.iq.leveldb.util.Finalizer$FinalizerQueueProcessor v, v;
java.lang.Thread v, v, v;
java.util.concurrent.ExecutorService v;
boolean v, v, v, v, v;
java.util.concurrent.ConcurrentHashMap v;
java.lang.Exception v;
java.lang.ref.Reference v;
org.iq.leveldb.util.Finalizer$FinalizerMonitor v;
java.lang.InterruptedException v;
v := @this: org.iq.leveldb.util.Finalizer$FinalizerQueueProcessor;
label:
v = v.<org.iq.leveldb.util.Finalizer$FinalizerQueueProcessor: org.iq.leveldb.util.Finalizer this$0>;
v = v.<org.iq.leveldb.util.Finalizer: java.util.concurrent.atomic.AtomicBoolean destroyed>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v != 0 goto label;
label:
v = v.<org.iq.leveldb.util.Finalizer$FinalizerQueueProcessor: org.iq.leveldb.util.Finalizer this$0>;
v = v.<org.iq.leveldb.util.Finalizer: java.lang.ref.ReferenceQueue referenceQueue>;
v = virtualinvoke v.<java.lang.ref.ReferenceQueue: java.lang.ref.Reference remove()>();
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
return;
label:
v = v.<org.iq.leveldb.util.Finalizer$FinalizerQueueProcessor: org.iq.leveldb.util.Finalizer this$0>;
v = v.<org.iq.leveldb.util.Finalizer: java.util.concurrent.ConcurrentHashMap references>;
virtualinvoke v.<java.util.concurrent.ConcurrentHashMap: java.lang.Object remove(java.lang.Object)>(v);
v = 0;
label:
specialinvoke v.<org.iq.leveldb.util.Finalizer$FinalizerPhantomReference: void cleanup()>();
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
v = virtualinvoke v.<java.lang.Thread: boolean isInterrupted()>();
label:
goto label;
label:
v := @caughtexception;
label:
v = v.<org.iq.leveldb.util.Finalizer$FinalizerQueueProcessor: org.iq.leveldb.util.Finalizer this$0>;
v = v.<org.iq.leveldb.util.Finalizer: org.iq.leveldb.util.Finalizer$FinalizerMonitor monitor>;
interfaceinvoke v.<org.iq.leveldb.util.Finalizer$FinalizerMonitor: void unexpectedException(java.lang.Throwable)>(v);
label:
goto label;
label:
v := @caughtexception;
label:
v = v instanceof java.lang.InterruptedException;
if v == 0 goto label;
v = 1;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
goto label;
label:
v = v instanceof java.lang.Error;
if v == 0 goto label;
v = 1;
label:
if v == 0 goto label;
v = v.<org.iq.leveldb.util.Finalizer$FinalizerQueueProcessor: org.iq.leveldb.util.Finalizer this$0>;
entermonitor v;
label:
v = v.<org.iq.leveldb.util.Finalizer$FinalizerQueueProcessor: org.iq.leveldb.util.Finalizer this$0>;
v = v.<org.iq.leveldb.util.Finalizer: java.util.concurrent.atomic.AtomicBoolean destroyed>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v != 0 goto label;
v = v.<org.iq.leveldb.util.Finalizer$FinalizerQueueProcessor: org.iq.leveldb.util.Finalizer this$0>;
v = v.<org.iq.leveldb.util.Finalizer: java.util.concurrent.ExecutorService executor>;
v = new org.iq.leveldb.util.Finalizer$FinalizerQueueProcessor;
v = v.<org.iq.leveldb.util.Finalizer$FinalizerQueueProcessor: org.iq.leveldb.util.Finalizer this$0>;
specialinvoke v.<org.iq.leveldb.util.Finalizer$FinalizerQueueProcessor: void <init>(org.iq.leveldb.util.Finalizer)>(v);
interfaceinvoke v.<java.util.concurrent.ExecutorService: java.util.concurrent.Future submit(java.lang.Runnable)>(v);
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return;
label:
return;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Throwable from label to label with label;
}
}