remplace la "private BlockingQueue queue" par une "private BlockingQueue< Message >", ou Message contient un reference vers un T, qui peut etre null pour signifier le EndOfStream (ou un flag, ou autre...).
Les consommateurs recoivent des Message, ils accedent a la valeur via un accesseur (toujours pas de cast).
Petite remarque en passant : les EndOfStream c'est bien quand tu connais le nombre de consommateurs a arreter (je ne sais pas si c'est dans la doc, je ne l'ai pas lue...)
# Encapsulation du T dans une classe "Message"
Posté par shbrol . En réponse au message Mettre un objet "end of stream" dans une queue paramétrée. Évalué à 1.
Les consommateurs recoivent des Message, ils accedent a la valeur via un accesseur (toujours pas de cast).
Petite remarque en passant : les EndOfStream c'est bien quand tu connais le nombre de consommateurs a arreter (je ne sais pas si c'est dans la doc, je ne l'ai pas lue...)