[jboss-user] [JBoss jBPM] - about implementation of JobExecutorThread
Hi gurus:
when I read code in JobExecutorThread.I got confused about the following code snip
| Collection acquiredJobs = acquireJobs();
|
| if (! acquiredJobs.isEmpty()) {
| Iterator iter = acquiredJobs.iterator();
| while (iter.hasNext() && isActive) {
| Job job = (Job) iter.next();
| executeJob(job);
| }
|
| } else { // no jobs acquired
| if (isActive) {
| long waitPeriod = getWaitPeriod();
| if (waitPeriod>0) {
| synchronized(jobExecutor) {
| jobExecutor.wait(waitPeriod);
| }
| }
| }
| }
|
acquiredJobs are retrieved by "
select job
from org.jbpm.job.Job as job
where ( (job.lockOwner is null) or (job.lockOwner = :lockOwner) )
and job.retries > 0
and job.dueDate <= :now
and job.isSuspended != true
order by job.dueDate asc"
so I dout that : is the job retrieved really is time to be executed? It's only the
latest job ,not anything else.
Can you guys explains a little for me? thanks a lot
View the original post :
http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4144869#...
Reply to the post :
http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&a...