about implementation of JobExecutorThread

[swenker]

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

[kukeltje]

why do you think it is only the latest job?

For me it is all jobs that have
- a specific lockowner or nolockowener
- more then 0 retries configured
- a due date that is in the past-
- are not suspended

so...

[swenker]

oh,I am sorry , you know, the result retrieved from db has been limited to the first one within java method.
What I really mean is : how can we assure that the acquired one is due to be executed?

[swenker]

I am understand this point now after noticing that the duedate 'value is a future time.