topic Re: Synchronized Access to ServiceTask in Alfresco Archive

Synchronized Access to ServiceTask

yangyang_qian — Wed, 24 Jul 2013 01:13:00 GMT

If I have a serviceTask that is always kicked off by various different nodes in the workflow (see the "Find Unfinished" task in the attachment) … but I don't want multiple threads to run the service task at exactly the same time (because they wouldn't want to make two copies for the same unfinished

Re: Synchronized Access to ServiceTask

jbarrez — Wed, 24 Jul 2013 09:51:37 GMT

There is no BPMN construct for this. Java based synchronized (probably within the execute()) method would be a solution

Re: Synchronized Access to ServiceTask

yangyang_qian — Wed, 24 Jul 2013 14:16:13 GMT

ok thanks, I guess something like the following would work then? (assuming that we can get our hands on a singleton ToyDb object and that the workflow engine only needs to run on one jvm)

<code>
import java.util.List;
import org.activiti.engine.delegate.DelegateExecution;
import org.activiti.engine.delegate.JavaDelegate;

public class ToyMaker implements JavaDelegate {
private static final ToyDb toys = ToyDb.getSingeltonInstance();

@Override
public void execute(DelegateExecution delegExec) throws Exception {
synchronized(toys) {
   // gets list of unfinished toys from somewhere …
   List<Toy> needFinishing = toys.getUnfinished();
   // … then do more stuff with the toys
   for (Toy toy : needFinishing) {
    toy.applyVarnish();
   }
}
}
}
</code>

… but this particular solution wouldn't work properly if the activiti engine was deployed across multiple jvms right? (i.e. if we eventually need two engine deployments pointed to one db)

Re: Synchronized Access to ServiceTask

trademak — Thu, 25 Jul 2013 11:34:30 GMT

That's correct, this only works within one jvm.

Best regards,

Re: Synchronized Access to ServiceTask

gordonko — Tue, 26 Aug 2014 00:49:33 GMT

I try to use process variable, instead of DB-based mutex, to implement the same thing but it did not work during a concurrency test. The biz logic always sneaks through and executed more than once

//////////////////////////////////
public void execute(DelegateExecution execution) {
synchronized (execution) {
   Boolean done = (Boolean) execution.getVariable("ConclusionDone");
   if ( done) {
     return;
   }
   execution.setVariable("ConclusionDone", true);
                  }
                  // do biz logic
   }

Does that mean the variable attached to the execution/process committed in an asynchronized approach. Can someone confirm it?

Re: Synchronized Access to ServiceTask

jbarrez — Sat, 30 Aug 2014 17:39:08 GMT

Is this for a single JVM?

Even so, it won't work. The execution is an object that is created on the fly, and thus you will have multiple similar objects for the same database row.

You will need a shared object instance to make it work that you share among the invocations.