Как я могу заблокировать метод до тех пор, пока счетчик объектов не достигнет> 0?

Question

Вы можете подумать, что класс странный, но он образовательный, поэтому я должен сделать это таким образом.

class petriPool { 
    private int[] nodes = new int[3]; 
    private int counter; 

    private readonly object _lock = new object(); 

    public petriPool (int n, int m) { 
     this.nodes[0] = n; 
     this.nodes[1] = 0; 
     this.nodes[2] = 0; 
     this.counter = m; 
    } 

    public bool start() { 
     lock (_lock) { 
      if (this.nodes[0] != 0 && counter != 0) { 
       this.nodes[0]--; 
       this.nodes[1]++; 
       counter--; 
       return true; 
      } else 
       return false; 
    }} 

    public bool stop() { 
     lock (_lock) { 
      if (this.nodes[1] != 0) { 
       this.nodes[1]--; 
       this.nodes[2]++; 
       counter++; 
       return true; 
      } else 
       return false; 
    }} 
} 

мне нужно сделать start() метод ждать, пока counter не получим значение > 0. Я могу это сделать:

public bool start() { 
    while (this.counter == 0) { 
     Thread.Sleep(10); 
    } 

    lock (_lock) { 
     if (this.nodes[0] != 0 && counter != 0) { 
      this.nodes[0]--; 
      this.nodes[1]++; 
      counter--; 
      return true; 
     } else 
      return false; 
}} 

Но нет ли лучшего решения? Я имею в виду, похоже, что я могу потерять меньше времени, чтобы спать.

Чтобы посмотреть, для чего это необходимо. Я вызываю start перед началом потока и stop в конце потока. Таким образом, счетчик должен отражать максимальное количество потоков, выполняемых в одно и то же время.

Answer 1

Сигнализация, как это делается с использованием классов событий. В вашем случае должно быть достаточно ManualResetEventSlim.

Вы можете использовать Wait вместо цикла while, и вы можете Set его, когда счетчик достигает нуля.

Answer 2

Вы можете придумать использование «ManualResetEvent» для измельчения между двумя потоками.

Следующий непроверенный код может помочь.

class petriPool 
{ 
    private int[] nodes = new int[3]; 
    private int counter; 
    private ManualResetEvent mevent; 

    private readonly object _lock = new object(); 

    public petriPool (int n, int m) 
    { 
     mevent= new ManualResetEvent(false); 
     this.nodes[0] = n; 
     this.nodes[1] = 0; 
     this.nodes[2] = 0; 
     this.counter = m; 
    } 

    public bool start() 
    { 
     lock (_lock) 
     { 
      if (this.nodes[0] != 0 && counter != 0) 
      { 
       this.nodes[0]--; 
       this.nodes[1]++; 
       counter--; 

       if(counter>0) mevent.Set(); 

       return true; 
      } else 
       return false; 
     } 
    } 

    public bool stop() 
    { 
     mevent.WaitOne(); 

     lock (_lock) { 


      if (this.nodes[1] != 0) { 
       this.nodes[1]--; 
       this.nodes[2]++; 
       counter++; 
       return true; 
      } else 
       return false; 
     } 

     //reset 'mevent' if you want. 
    } 
}