/**
 * @license
 * Copyright 2019 The FOAM Authors. All Rights Reserved.
 * http://www.apache.org/licenses/LICENSE-2.0
 */

package foam.util.concurrent;

import foam.core.Agency;
import foam.core.ContextAgent;
import foam.core.X;

/**
* An Aynchronous implementation of the AssemblyLine interface.
* Uses the threadpool to avoid blocking the caller.
**/
public class AsyncAssemblyLine
  extends SyncAssemblyLine
{
 protected Agency pool_;
 protected X      x_;

 public AsyncAssemblyLine(X x) {
   x_    = x;
   pool_ = (Agency) x.get("threadPool");
 }

 public void enqueue(Assembly job) {
   final Assembly previous;

   synchronized ( startLock_ ) {
     try {
       previous = q_;
       q_ = job;
       job.executeUnderLock();
       job.startJob();
     } catch (Throwable t) {
       q_ = previous;
       throw t;
     }
   }

   pool_.submit(x_, new ContextAgent() { public void execute(X x) {
     try {
       job.executeJob();

       if ( previous != null ) previous.waitToComplete();

       synchronized ( endLock_ ) {
         job.endJob();
         job.complete();
       }
     } finally {
       // Isn't required, but helps GC last entry.
       synchronized ( startLock_ ) {
         // If I'm still the only job in the queue, then remove me
         if ( q_ == job ) q_ = null;
       }
     }
   }}, "SyncAssemblyLine");
 }
}

/**
 * @license
 * Copyright 2019 The FOAM Authors. All Rights Reserved.
 * http://www.apache.org/licenses/LICENSE-2.0
 */

package foam.util.concurrent;

import foam.core.Agency;
import foam.core.ContextAgent;
import foam.core.X;

/**
* An Aynchronous implementation of the AssemblyLine interface.
* Uses the threadpool to avoid blocking the caller.
**/
public class AsyncAssemblyLine
  extends SyncAssemblyLine
{
 protected Agency pool_;
 protected X      x_;

 public AsyncAssemblyLine(X x) {
   x_    = x;
   pool_ = (Agency) x.get("threadPool");
 }

 public void enqueue(Assembly job) {
   final Assembly previous;

   synchronized ( startLock_ ) {
     previous = q_;
     q_ = job;
     try {
       job.executeUnderLock();
       job.startJob();
     } catch (Throwable t) {
       q_ = previous;
       throw t;
     }
   }

   pool_.submit(x_, new ContextAgent() { public void execute(X x) {
     try {
       job.executeJob();

       if ( previous != null ) previous.waitToComplete();

       synchronized ( endLock_ ) {
         job.endJob();
         job.complete();
       }
     } finally {
       // Isn't required, but helps GC last entry.
       synchronized ( startLock_ ) {
         // If I'm still the only job in the queue, then remove me
         if ( q_ == job ) q_ = null;
       }
     }
   }}, "SyncAssemblyLine");
 }
}

Fix unitialized variable compiler error