Licence CC BY-NC-ND

Les acteurs à la rescousse des philosophes

Le classique problème des philosophes

J’ai déjà plus ou moins parlé du modèle d’acteurs de Ruby dans ce billet. L’idée est d’avoir une abstraction pour faciliter la tâche d’écriture de programmes concurrents.

Le modèle d’acteurs permet d’avoir plusieurs tâches s’exécutant en parallèle dans leurs threads, sans partager leurs données de manière directe. Ainsi, il y a beaucoup moins de problème d’accès concurrent à une ressource vu que les acteurs sont isolés dans leur bulle. Pour communiquer, ils peuvent cependant s’envoyer des messages.

Dans ce billet, nous allons utiliser ce modèle pour résoudre le fameux problème du dîner de philosophes. L’idée est la suivante : un groupe de n philosophes se retrouve autour d’une table (ronde) pour manger des spaghetti. Chacun a son plat devant lui et à gauche de chaque plat se trouve une fourchette.

Un philosophe fait deux choses : manger et penser. Il commence par penser pendant un certain temps, ce qui lui creuse fortement l’estomac. Il décide alors de manger. Pour cela, il doit prendre la fourchette à gauche de son assiette, et celle à gauche de l’assiette de son voisin (de droite).

On se rend tout de suite compte que si un philosophe est en train de manger, alors ses voisins ne peuvent pas manger ! Il pourrait essayer d’arracher les fourchettes des mains de ses voisins, mais ce ne serait pas très courtois… Donc si les fourchettes ne sont pas disponibles, on va dire qu’il se remet à penser avant de réessayer. S’il réussit à avoir les fourchettes, il mange pendant un certain temps, puis nettoie les fourchettes et les redépose.

Votre mission, si vous l’acceptez, est de faire en sorte que chaque philosophe mange. Pour plus d’information sur les modalités du problème, ne pas hésiter à lire la page Wikipedia

Cette situation est celle de différents tâches (les philosophes) qui ont besoin de ressources (les fourchettes) pour s’exécuter et c’est donc un problème classique de programmation concurrente et de partage de ressources.

En particulier, on peut facilement se retrouver dans une situation d'interblocage : chaque philosophe prend la fourchette a sa gauche puis attend que la deuxième fourchette dont il a besoin soit libre.


Dans notre résolution du problème, chaque philosophe sera un acteur. Et nous aurons un acteur supplémentaire, un serveur en costume trois pièces (avec cravate et pochette assortie). Ce serveur sera le seul à gérer les ressources (les fourchettes).

  • Quand un philosophe a fini de penser, il n’essaye pas de prendre les fourchettes, il appelle le serveur et lui demande s’il peut manger. Le serveur regarde alors si les fourchettes sont libres et les lui donne si c’est le cas.
  • Quand un philosophe a fini de manger, il appelle le serveur, lui dit qu’il a fini et lui remet les fourchettes.

Ici, on a code qui correspond à peu près à cette idée. Il manque juste le passage de ressources du serveur aux philosophes ; mon serveur a juste un tableau indiquant si les fourchettes sont libres.

class Waiter
  def initialize(n)
    @forks = Array.new(n, false) 
  end
  
  def call?(i, j)
    if @forks[i] || @forks[j]
      print "Les couverts #{i} et #{j} ne sont pas libres.\n"
      false 
    else
      print "Les couverts #{i} et #{j} sont libres.\n"
      @forks[i] = true
      @forks[j] = true
      true
    end
  end
  
  def clean(i, j)
    @forks[i] = false
    @forks[j] = false
  end
end

class Philosopher
  def initialize(name, waiter, left_fork, right_fork)
    @name = name
    @waiter = waiter
    @left_fork = left_fork
    @right_fork = right_fork
  end
  
  def think
    print "#{@name} pense\n"
    sleep(rand(3..8))
  end
  
  def eat
    print "#{@name} mange.\n"
    sleep(3)
    @waiter.send([Ractor.current, :end, @left_fork, @right_fork])
  end

  def run
    loop do
      think
      @waiter << [Ractor.current, :hungry, @left_fork, @right_fork]
      eat if Ractor.recv
    end
  end
end

waiter = Waiter.new(4)
philosophers = ["Aristote", "Platon", "Nietzsche", "Descartes"]
n = philosophers.size
ractors = philosophers.each_with_index.map do |name, i|
  r = Ractor.new(name, i, (i + 1) % n, Ractor.current) do |p_name, j, k, waiter|
    p = Philosopher.new(p_name, waiter, j, k)
    p.run
  end
end

loop do
  p, m, i, j = Ractor.recv
  p << waiter.call?(i, j) if m == :hungry
  waiter.clean(i, j) if m == :end
end

Je vous laisse comprendre le code qui n’est pas vraiment compliqué et retranscrit assez bien l’idée décrite. L’acteur principal est dédié au serveur ; il reçoit les messages des philosophes et les traite. Chaque philosophe est dans son acteur, demande au serveur s’il peut manger et le prévient quand il a terminé.



2 commentaires

Salut,

Merci pour ce billet que je prendrai le temps de regarder à nouveau à tête reposée.

Je n’ai pas refait de Ruby récemment et il y a quelques points qui m’interrogent dans le code, donc j’aimerais bien avoir tes éclaircissements.

@waiter.send([Ractor.current, :end, @left_fork, @right_fork])
  • Dans mes souvenirs la méthode send permet d’appeler une méthode particulière en indiquant son nom et ses arguments. Ici tu passes un tableau de valeurs, à quoi ça correspond, qu’est-ce qui est appelé derrière ?
@waiter << [Ractor.current, :hungry, @left_fork, @right_fork]
  • Pareil ici, je ne vois pas dans l’objet Waiter ce qui permet d’utiliser cet opérateur. Comment est-ce que ça enclenche l’envoi du message et quelle différence avec le send plus haut ?

Merci.

C’est de ma faute. Je devais l’appeler waiter_actor plutôt que waiter car ce n’est pas un élément de la classe Waiter qui est attendu mais bien un élément de la classe Ractor (au début je voulais faire une classe Waiter qui hérite de Ractor ou qui possède un acteur mais finalement je ne l’ai pas fait). Ça explique les deux points suivant. Un Ractor a une méthode << qui permet de lui envoyer un message. Cette méthode a comme alias send (qui sera sûrement supprimé car comme tu l’as dit, send permet normalement d’appeler une méthode de l’objet).

C’est dans le bout de code suivant qu’on voit comment est créé chaque philosophe.

 r = Ractor.new(name, i, (i + 1) % n, Ractor.current) do |p_name, j, k, waiter|
    p = Philosopher.new(p_name, waiter, j, k)
    p.run
  end

On peut donner des arguments aux constructeur de Ractor. Ces éléments seront alors récupérés dans le Ractor correspondant dans le bloc uq’on utilise pour le créer. Ainsi, waiter dans le bloc correspond à Ractor.current (qui est ici l’acteur principal du programme) et c’est cet acteur qu’on utilise pour créer chaque philosophe.

Finalement, @waiter dans le philosophe correspond à l’acteur principal du programme. Quand les philosophes envoient un message, on le récupère ici et on lui répond si besoin en lui envoyant un message avec <<, p correspond à l’acteur du philosophe qui a envoyé le message (dans chaque message qu’il envoie, un philosophe envoie d’abord l’acteur qui lui correspond, ce qui permet de savoir facilement à qui répondre).

loop do
  p, m, i, j = Ractor.recv # Ici
  p << waiter.call?(i, j) if m == :hungry  # La réponse
  waiter.clean(i, j) if m == :end
end
+1 -0
Connectez-vous pour pouvoir poster un message.
Connexion

Pas encore membre ?

Créez un compte en une minute pour profiter pleinement de toutes les fonctionnalités de Zeste de Savoir. Ici, tout est gratuit et sans publicité.
Créer un compte