Liste de processus <T> membre lorsqu'il est ajouté dans un thread séparé

Question

Donc d'abord voici un pseudo code de ce que je veux améliorer.

 
     public List<ProcessData> Processes; 
     System.Threading.Thread ProcessThread; 
     void ProcessLoop() 
     { 
      while (true) 
      { 
       for (int i = 0; i < Processes.Count; i++) 
       { 
        if (HasPriority(Processes[i])) 
        { 
         Process(Processes[i]); 
        } 
       } 
       System.Threading.Thread.Sleep(1000); 
      } 

     } 
     void AddProcessData(ProcessData pd) 
     { 
      Processes.Add(pd); 
      if (Suspended(ProcessThread)) 
       Resume(ProcessThread); 
     } 
     void Startup() 
     { 
      ProcessThread = new System.Threading.Thread(ProcessLoop); 
      ProcessThread.Start(); 
     } 

Donc ce que je veux faire est de remplacer le « sommeil » avec le code qui suspend le fil ou le faire attendre quelque chose est ajouté à la liste, puis la reprendre. J'ai également besoin d'être thread safe, bien sûr.

Answer 1

Ce que vous voulez est un événement.

EDIT: pour rendre le filetage sûr.

public List<ProcessData> Processes; 
    System.Threading.Thread ProcessThread; 
    System.Threading.AutoResetEvent ProcessesChangedEvent = new System.Threading.AutoResetEvent(false); 
    void ProcessLoop() 
    { 
     while (true) 
     { 
      // You might want to copy out the entire list as an array instead 
      // if HasPriority or Process take a long time. 
      lock (Processes) 
      { 
       for (int i = 0; i < Processes.Count; i++) 
       { 
        if (HasPriority(Processes[i])) 
        { 
         Process(Processes[i]); 
        } 
       } 
      } 
      ProcessesChangedEvent.WaitOne(...); // timeout? 
     } 

    } 
    void AddProcessData(ProcessData pd) 
    { 
     lock (Processes) 
      Processes.Add(pd); 
     ProcessesChangedEvent.Set(); // you can also use Monitor.PulseAll/Wait 
    } 
    void Startup() 
    { 
     ProcessThread = new System.Threading.Thread(ProcessLoop); 
     ProcessThread.Start(); 
    } 

Answer 2

Découvrez le framework RX de Microsoft. http://rxwiki.wikidot.com/start là vous pouvez obtenir un événement toutes les x secondes et faire quelque chose ensuite. pas besoin de démarrer les threads du tout.

ou d'utiliser une minuterie et d'effectuer la vérification dans l'événement écoulé.

Answer 3

Dans votre cas le plus desicion est d'utiliser une des classes suivantes: ManualResetEvent ou AutoResetEvent

Answer 4

Juste au cas où vous avez vraiment besoin de traiter les données qu'une seule fois, voici un code

     public Queue<ProcessData> Processes; 
     System.Threading.Thread[] ProcessThreads = new System.Threading.Thread[5]; 
     System.Threading.Semaphore semToDo = new System.Threading.Semaphore(0,int.MaxValue); 

     void ProcessLoop() 
     { 
      ProcessData pd; 

      while (true) 
      { 
       semToDo.WaitOne(); 
       lock (Processes) 
       { 
        pd = Processes.Dequeue();      
       } 
       Process(pd); 
      } 
     } 

     private void Process(ProcessData processData) 
     { 
      throw new NotImplementedException(); 
     } 

     void AddProcessData(ProcessData pd) 
     { 
      lock (Processes) 
      { 
       Processes.Enqueue(pd); 
      } 
      semToDo.Release(); 
     } 
     void Startup() 
     { 
      //you can even have multiple worker threads now! 

      for(int i = 0; i < 5; i++) 
       ProcessThreads[i] = new System.Threading.Thread(ProcessLoop); 
      foreach (System.Threading.Thread t in ProcessThreads) 
      { 
       t.Start(); 
      } 
     } 

Answer 5

Ce dont vous avez vraiment besoin est un BlockingQueue. Vous pouvez trouver une implémentation de qualité here. Ou si vous utilisez la version 4 du .NET Framework, vous pouvez utiliser la classe BlockingCollection intégrée. Remarquez combien le code est plus facile lorsque vous utilisez ce type de structure de données.

public class YourClass 
{ 
    private BlockingQueue<ProcessData> m_Queue = new BlockingQueue<ProcessData(); 

    private void ProcessLoop() 
    { 
    while (true) 
    { 
     ProcessData item = m_Queue.Dequeue(); 
     if (HasPriority(item)) 
     { 
     Process(item); 
     } 
    } 
    } 

    public void AddProcessData(ProcessData item) 
    { 
    m_Queue.Enqueue(item); 
    } 

    public void Startup() 
    { 
    var thread = new Thread(() => { ProcessLoop(); }); 
    thread.Start(); 
    } 
}