Discussion :

[kodo]

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

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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.

[kodo]

Bonjour,
Le problème est localisé.

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

public class MyAppJob implements StatefulJob {

En implémentant directement l'interface job, le problème ne se reproduit plus.