Parallelisation de code

Hello,
J'essai de paralléliser une partie de mon application. A la base, j'importe des objets à partir d'un fichier dans une base de données. Comme je suis suceptible d'en importer plusieurs millions, je souhaite paralléliser mon import.

J'ai un problème lorsque je crée mon objet java à partir de sa représentation dans le fichier. Une exception est levée, mais je ne la maitrise pas car elle se situe dans le code d'une librairie jar externe, qui n'est donc à prioris pas thread safe.

Vioci le code du constructeur ainsi que l'endroit exacte où l'exception (ArrayOutOfBounds) est levée:

Code:

---

1 2 3 4 5 6 7 8 9 10

public MyObject (String rep) { super(rep) ; InputStream is = new ByteArrayInputStream(rep.getBytes("UTF-8")) ;   SimpleReader sr = new SimpleReader(is, sdfType) ; sr.readNext(this.o) ; // Exception sr.close(); }

---

Sachant que je ne maitrise pas le code qui lève l'exception, y'a t-il un moyen de contourner ce genre problème ?

Merci d'avance!

Citation:

---

Envoyé par vinzzzz

Sachant que je ne maitrise pas le code qui lève l'exception, y'a t-il un moyen de contourner ce genre problème ?

Merci d'avance!

---

Tu veux dire que tu ne maitrise pas le MyObject? A priori, cette exception est levée car tu fournis en paramètre un String qui ne correspond pas à ce à quoi il s'attends. Sinon, un try catch autour de l'appel à new MyObject() suffirais à gérer l'exception.

Je pense qu'il parle plutôt de la classe SimpleReader.
Le problème c'est que nous n'avons pas non plus le code ou même la documentation de cette classe, donc impossible de dire pourquoi ça plante. Moi je vote pour un problème de sérialisation/desserialisation (ça se dit?)

Qu'est ce qui te fait penser que ton erreur est liée à la synchronisation? Ca marche quand tu lances ton appli une fois mais plante quand tu la lances plein de fois en même temps c'est ça?

Oui c'est bien ca: ca marche en une fois, mais dés que plusieurs thread sont lancés, ca plante. Ca n'est même pas dans la classe SimpleReader que ca plante: c'est dans d'autrs classes appelées par la méthode readNext.

Ca devient compliqué de paralléliser des traitements lorsqu'on utilise des librairies tierces n'ayant pas été pensé pour l'être...

C'est pour ça qu'on a crée les blocs "synchronized" ;)

Juste une intuition: sdfType, ce serait pas un objet SimpleDateFormat par hasard?
Si c'est le cas c'est la cause de ton problème: les classes XXXXXFormat de l'API java utilisent des buffers internes qui font que même pour un simple parse() ou format() on risque des problèmes d'accès concurrents.
Donc: il ne vaut mieux pas partager ce genre d'objet.

Nope c'est un objet spécifique et ca n'est pas lui la cause :)

Je vais donc y aller a coup de synchronized..