Quartz et parallélisme

Bonjour,
Je commence par ces bouts de code avant d'introduire mon sujet :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
org.quartz.scheduler.instanceName = myApp-Scheduler
org.quartz.scheduler.rmi.export = false
org.quartz.scheduler.rmi.proxy = false
org.quartz.scheduler.wrapJobExecutionInUserTransaction = false
org.quartz.scheduler.threadsInheritContextClassLoaderOfInitializer = true 
 
#============================================================================
# Configure ThreadPool  
#============================================================================
 
org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount =10
org.quartz.threadPool.threadPriority = 5

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
public class MyAppJob implements StatefulJob {
 
	public void execute(JobExecutionContext context)
			throws JobExecutionException {
		Log.info(MyAppJob.class, "Demarrage du batch MyAppJob " + Thread.currentThread().getName());
		try {
			if(Thread.currentThread().getName().equals("myApp-Scheduler_Worker-3")){
				Log.warn("==============================>myApp-Scheduler-3 en attente");
				for(int t = 0;t<100000000;t++){
					Log.debug(MyAppJob.class, "Boucle");
				}
			}
			Log.info(MyAppJob.class, "Fin du batch MyAppJob"+ Thread.currentThread().getName());
		} catch (Exception e) {
			Log.error(MyAppJob.class, e);
			e.printStackTrace();
			throw new JobExecutionException(e);
		}
	}
}

Code:

1
2
3
4
5
6
7
<trigger>
		<cron>
			<name>MyAppJob</name>
			<start-time>2003-12-17T14:15:00</start-time>
			<cron-expression>0/1 0/1 * 1/1 * ? *</cron-expression>
		</cron>
	</trigger>

Comme vous pouvez lire, avec ce code, j'essaie de lancer mon Job avec 10 threads chaque seconde, avec simulation 'un traitement qui dure dans le temps dans le cas de thread 3.

Ma remarque, est que quand c'est le tour de thread 3, je ne vois plus les logs des autres threads. C'est comme si j'ai un traitement en séquentielle.

Avez vous une idée sur les config ou le code, que je dois ajouter/modifier pour avoir du parallélisme entre mes 10 threads.

Merci.