@Override
    public void run() {
        ObjectInputStream e = null;
        ObjectOutputStream s = null;
        
        try {
            e = new ObjectInputStream(entree);
            s = new ObjectOutputStream(sortie);
            
            while(!this.Interrupted) {
                Commande data = (Commande) e.readObject();

                int nbPieceRatees = this.MakeThem(data);
                System.out.println("Nombre de pièce ratées : " + String.valueOf(nbPieceRatees));

                s.writeObject(data);
            }
        }
        catch (IOException ex) {
            System.out.println("Erreur rencontrée dans la classe : "+ Fen_Princ.class.getName());
            System.out.println("Problème d'I/O concernant le pipeline.");
            System.out.println(ex);
        }
        catch (InterruptedException ex) {
            this.Interrupted = true;
            Thread.currentThread().interrupt();
        }
        catch (ClassNotFoundException ex) {
            System.out.println("Erreur rencontrée dans la classe : "+ Fen_Princ.class.getName());
            System.out.println("Classe renseignée non trouvée.");
            System.out.println(ex);
        }
        finally {
            try {
                e.close();
                s.close();
            }
            catch (IOException ex) {
                System.out.println("Erreur rencontrée dans la classe : "+ Fen_Princ.class.getName());
                System.out.println("Problème d'I/O lors de la fermeture du pipeline.");
                System.out.println(ex);
            }
        }
    }