Discussion :

[zemzoum89]

Bonjour,

voilà j'ai un objet disant qui a une méthode

recoietravail (tache) et il return un objet de type resultat, je voudrai savoir comment récupérer le résultat du coté de la machine qui a appelé cette méthode distante... Merci pour votre aide...

[Alkhan]

bonjour,

Si c'est en RMI comme indiqué dans le titre, alors le résultat est récupéré de la même façon qu'un appel local. La différence est simplement que l'objet qui est retourné par l'appel distant doit être sérialisable.

[zemzoum89]

Ahh ok merci beaucoup pour votre aide merciii... la j'ai un problème de Thread je vous explique,

j'ai une ArrayList et tant qu'elle n'est pas vide je lance un thread qui récupere une valeur de l'arraylist (l'arraylist et synchronized) mais mon probleme c'est meme si la liste est vide les thread continue à se créer et à parcour la liste meme si elle est vide pouvez vous m'aider svp...

[Alkhan]

sans voir le code c'est difficile de dire quoi que ce soit !

j'ai une ArrayList et tant qu'elle n'est pas vide je lance un thread qui ....

Je dirais que le test de l'état vide de l'ArrayList n'est pas bon !

Mais comme je l'ai dis sans voir le code difficile d'en dire plus.

[zemzoum89]

je vous explique le problème et après je poste le code...

A chaque tour de boucle je récupère un objet et j'appelle et je cherche un volontaire libre (non actif) des que je trouve un je lance un thread qui appelle une méthode distante et met le résultat dans job.addResult dans une autre arraylist destinée aux résultats... mais le problème c'est que le résultat est renvoyé avant que les Threads n'aient terminé leur travail et en plus de ca le travail est effectué par un seul volontaire alors qu'il y a le test... Merci beaucoup de m'aider...

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
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
static int i=0;
	@Override
	public ArrayList<Result> compute(final Job job) throws RemoteException, InterruptedException {
		for (int i = 0; i < job.tasks.size(); i++) {
			tasks.add(job.tasks.get(i));
		}
		while (!tasks.isEmpty()) {
			System.out.println(tasks.size()+" j'envoie la tache " + i++);
			final Task ta = tasks.remove(0);
			int j=0; 
			try {
 
				while (volunteers.get(j).getActivity()==true) {
					while (j<volunteers.size())
					{
						j++;
					}
					j=0;
				}
 
 
 
			volunteers.get(j).setActivity(true);
			} catch (RemoteException e1) {
				e1.printStackTrace();
			}
			final int k = j;
			final IVolunteer vol = volunteers.get(j);
 
 
 
					//	synchronized(volunteers){
					try {
						job.addNewResult(vol.receiveTask(ta));
						volunteers.get(k).setActivity(false);
					} catch (RemoteException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					} catch (InterruptedException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
					//}
				}
 
 
		//	System.out.println("Je suis sorti du Thread " + i + " en "+ System.currentTimeMillis());
 
 
		System.out.println("Je suis sorti de la boucle while");
		return job.results;
	}