class org.jvnet.hk.config.Transactions$Notifier$1 extends java.lang.Object implements java.lang.Runnable
{
final org.jvnet.hk.config.Transactions$Notifier this$1;
void <init>(org.jvnet.hk.config.Transactions$Notifier)
{
org.jvnet.hk.config.Transactions$Notifier$1 v;
org.jvnet.hk.config.Transactions$Notifier v;
v := @this: org.jvnet.hk.config.Transactions$Notifier$1;
v := @parameter: org.jvnet.hk.config.Transactions$Notifier;
v.<org.jvnet.hk.config.Transactions$Notifier$1: org.jvnet.hk.config.Transactions$Notifier this$1> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void run()
{
java.util.concurrent.BlockingQueue v;
long v;
java.util.concurrent.CountDownLatch v;
byte v;
java.lang.InterruptedException v;
org.jvnet.hk.config.Transactions v;
org.jvnet.hk.config.Transactions$Notifier v, v, v;
org.jvnet.hk.config.Transactions$Notifier$1$1 v;
java.lang.Object v;
org.jvnet.hk.config.Transactions$Notifier$1 v;
java.util.concurrent.ExecutorService v;
v := @this: org.jvnet.hk.config.Transactions$Notifier$1;
label:
v = v.<org.jvnet.hk.config.Transactions$Notifier$1: org.jvnet.hk.config.Transactions$Notifier this$1>;
v = v.<org.jvnet.hk.config.Transactions$Notifier: java.util.concurrent.CountDownLatch latch>;
v = virtualinvoke v.<java.util.concurrent.CountDownLatch: long getCount()>();
v = v cmp 0L;
if v <= 0 goto label;
label:
v = v.<org.jvnet.hk.config.Transactions$Notifier$1: org.jvnet.hk.config.Transactions$Notifier this$1>;
v = v.<org.jvnet.hk.config.Transactions$Notifier: java.util.concurrent.BlockingQueue pendingJobs>;
v = interfaceinvoke v.<java.util.concurrent.BlockingQueue: java.lang.Object take()>();
v = v.<org.jvnet.hk.config.Transactions$Notifier$1: org.jvnet.hk.config.Transactions$Notifier this$1>;
v = v.<org.jvnet.hk.config.Transactions$Notifier: org.jvnet.hk.config.Transactions this$0>;
v = v.<org.jvnet.hk.config.Transactions: java.util.concurrent.ExecutorService executor>;
v = new org.jvnet.hk.config.Transactions$Notifier$1$1;
specialinvoke v.<org.jvnet.hk.config.Transactions$Notifier$1$1: void <init>(org.jvnet.hk.config.Transactions$Notifier$1,java.util.concurrent.FutureTask)>(v, v);
interfaceinvoke v.<java.util.concurrent.ExecutorService: java.util.concurrent.Future submit(java.lang.Runnable)>(v);
label:
goto label;
label:
v := @caughtexception;
goto label;
label:
return;
catch java.lang.InterruptedException from label to label with label;
}
}