Les threads Java ne fonctionnent pas correctement avec la liste liée

Question

Bonjour, Je travaille sur le problème du coiffeur qui dort. avec l'addition d'avoir un client prioritaire quand ils arrivent ils vont en première ligne et ils sont les prochains à se faire couper les cheveux.

J'utilise un linkedlist et si je vois un client prioritaire je le mets au début de la liste, si le client n'est pas prioritaire il va à la fin de la liste. alors j'appelle la méthode wantHaircut pour obtenir le premier élément de la liste. Mon problème est que les clients sont traités dans l'ordre où ils arrivent, et le client prioritaire doit attendre. voici le code où tout se passe. des idées que je fais mal? grâce

public void arrivedBarbershop(Customer c){ 

     if(waiting < numChairs && c.isPriority()){ 
      System.out.println("Customer " + c.getID() + ": is a priority customer - SITTING -"); 
      mutex.up();    
      customer_list.addFirst(c); 
     } 
     else if(waiting >= numChairs && c.isPriority()){ 
      System.out.println("Customer " + c.getID() + ": is a priority customer - STANDING -"); 
      mutex.up(); 
      customer_list.addFirst(c); 
     } 
     else if(waiting < numChairs && !c.isPriority()){ 
      waiting++; 
      System.out.println("Customer " + c.getID() + ": arrived, sitting in the waiting room"); 
      customer_list.addLast(c); 
      customers.up(); // increment waiting customers 

     } 
     else if(waiting >= numChairs && !c.isPriority()) { 

     System.out.println("Customer " + c.getID() + ": went to another barber because waiting room was full - " + waiting + " waiting"); 
     mutex.up(); 
     } 

     if(!customer_list.isEmpty()){ 
     this.wantHairCut(customer_list.removeFirst()); 
     } 

    } 

    public void wantHairCut(Customer c) { 
      mutex.up(); 
      barber.down(); // waits for being allowed in barber chair 
      System.out.println("Customer " + c.getID() + ": getting haircut"); 
      try { 
      /** haircut takes between 1 and 2 seconds **/ 
       Thread.sleep(Barbershop.randomInt(1, 2) * 1000); 
      } catch (InterruptedException e) { } 
      System.out.println("Barber: finished cutting customer " + c.getID() + "'s hair"); 
      c.gotHaircut = true;   
      cutting.up(); // signals cutting has finished 

      /** customer must pay now **/ 
      this.wantToCashout(c);   
    } 

Answer 1

vous devez utiliser les collections synchronisées:

Collections.synchronizedList(List<Object> list) 

cette méthode retourne Liste synchronisée instanse basée sur la liste des paramètres

Answer 2

Je suis sûr que l'erreur logique est ici:

if(waiting < numChairs && c.isPriority()){ 
     System.out.println("Customer " + c.getID() + ": is a priority customer - SITTING -"); 
     mutex.up();    
     customer_list.addFirst(c); 
    } 
    else if(waiting >= numChairs && c.isPriority()){ 
     System.out.println("Customer " + c.getID() + ": is a priority customer - STANDING -"); 
     mutex.up(); 
     customer_list.addFirst(c); 
    } 

Et oui, évitez de copier/coller la programmation !

Answer 3

Chaque fois que vous modifiez votre liste, vous devriez probablement mettre ce code sur un bloc synchronisé.

Une façon de le faire:

synchronized(customer_list) { 
customer_list.addFirst(c); 
} 

Une autre, de sorte que vous n'avez pas à code dans tous les sens:

public synchronized void addCustomerAtStart(Customer c) { 
customer_list.addFirst(c); 
} 

puis remplacer cette fonction. Même chose lorsque vous effectuez customer.up(), il semble que la synchronisation soit également nécessaire, sinon vous risquez d'avoir beaucoup de comportements incohérents. Astuce: Si vous devez synchroniser des threads, vous pouvez jeter un oeil à CountDownLatch, très facile à utiliser, fonctionne solidement pour la synchronisation des threads. .

Answer 4

Votre code ajoute un client à la liste (début ou fin), puis supprime un client de la liste. La liste ne contient jamais qu'un client au maximum, les clients sont donc traités dans l'ordre dans lequel ils ont été ajoutés.