Discussion :

[facilus68]

Bonjour,

J'ai une liste initial contenant un ensemble de nom de fichiers (supposant 20).

J'ai un ensemble de threads (supposant 3) qui traiteront les elements de liste de cette maniere :

- Chaque thread a une liste, elle contient un ensemble de la liste initial (Thread 1 contient 7, Thread 2 contient 7 et Thread 3 contient 6)
- Le traitement se fait sur chaque element de la liste du thread

En ce moment j'ai pu repartir la liste initial sur l'ensemble des listes

Quand j'esseye de parcourir la liste du thread dans le thread (methode run), j'ai cette exception :

Code :

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

1
2
3
4
Exception in thread "Thread-2" java.util.ConcurrentModificationException
	at java.util.concurrent.CopyOnWriteArrayList$COWSubList.checkForComodification(CopyOnWriteArrayList.java:1127)
	at java.util.concurrent.CopyOnWriteArrayList$COWSubList.size(CopyOnWriteArrayList.java:1167)
	at fr.gouv.finances.tools.sftppoller.poller.ThreadReader.run(ThreadReader.java:21)

La premiere partie de la methode run est :

Code :

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

1
2
3
4
5
6
7
8
9
Iterator<String> it = getOwnFiles().iterator();
		while (it.hasNext()) {
			if (!Poller.toStop) {
				logger.debug("Taille de la OwnFiles : " + getOwnFiles().size());
				String fileName = it.next();
                        ...
                        }
                 ...
                }

La liste du thread OwnFiles est initialisé de cette maniere :

Code :

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

private List<String> ownFiles = new CopyOnWriteArrayList<String>();

Comment résoudre ce probleme ?

Merci

[eulbobo]

Quand tu travailles avec un CopyOnWriteArray, il faut te dire que quasiment toutes les opérations sur la liste te renvoie une NOUVELLE image de la liste.

En gros, quand tu demandes un Iterator sur ton array, tu obtiens un iterateur qui pointe sur une copie locale de la liste au moment où tu as demandé l'itérateur. Du coup, ton code n'a pas de raison de planter là

Par contre, en faisant un .size(), tu faut que tu aies conscience que cet élément fait référence à l'état général de ton objet list (qui peut donc varier)


Maintenant, l'erreur que tu as n'est pas cohérente avec ton code : ce genre d'erreur ne peut à priori arriver que si tu utilises un subList à un moment ou à un autre (qui te renvoie une liste qui N'EST PAS une CopyOnWriteArray)

[facilus68]

Oui,j'utilise bien une sublist pour remplir les differentes ownListdes threads de cette maniere :

Code :

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

files.subList(j, nbFilesInThread + j)

sachant que la liste files est bien du type

Code :

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

CopyOnWriteArrayList

[adiGuba]

Salut,


Les List retournée par subList() correspondent à des vues sur la liste principale.
Dans le cas d'une CopyOnWriteArrayList, si la liste originale est modifiée la vue est invalide : https://docs.oracle.com/javase/8/doc...bList-int-int-


Tu veux faire quoi exactement avec tout çà ? Ca me semble un peu lourd d'utiliser une CopyOnWriteArrayList !


a++

[facilus68]

J'ai redéfini la méthode subList et j'ai plus cette erreur.

je vous remercie pour votre aide

[adiGuba]

Mouais... mais c'est quoi le but du traitement ? Il doit sûrement y avoir plus simple...


a++

[facilus68]

Le but du traitement est de traiter une liste contenant un ensemble fichiers avec plusieurs threads.

Pour cela, la solution qu'on a choisie est de crée une liste pour chaque thread, ces listes sont alimenter en fonction du nombre de la liste principale

[adiGuba]

Mais pourquoi passer par une CopyOnWriteArrayList ? Un liste par thread serait amplement suffisant...

Sans même parler de l'API de Stream de Java 8.


a++

[facilus68]

Initialement ce n'etait pas une CopyOnWriteArrayList , c'etait ArrayList

On chercheons une solution sur le net, j'ai trouvé que c'est recommandé de changé ArrayList par CopyOnWriteArrayList

Dans ce lien : mettre la CopyOnWriteArrayList

[adiGuba]

Dans ce lien : mettre la CopyOnWriteArrayList

Je trouve cette solution carrément affreuse !!! C'est sale.


J'espère que ton jeu de données restera toujours très "petit" car le contraire risquerait de poser problème...


a++