すぐにすべてのスレッドを殺す方法

Question

2つのスレッドを使って数値を数える小さなプログラムを作った。それはまた、カウントの隣に2番目の数字を表示するので、どのスレッドがどの番号を表示しているかを見ることができます。

私の目標は、それらのうちの1つが7とカウントされるとすぐに両方のスレッドを停止させることです。私はそれについてどうなるかわかりません。私はCounterへのパラメータとしてスレッド配列を渡すことを考え、両方のスレッドを中止するためにforeachループを使用します。問題はt0がそれを実行している可能性があり、t0.Abort()を呼び出すため、t1.Abort()はもう呼び出されないということです。

public static int count = 0; 
private static object lockObject = new object(); 

static void Main(string[] args) { 
    Thread t0 = new Thread(() => Counter(1, 10)); 
    Thread t1 = new Thread(() => Counter(10, 20)); 

    t0.Start(); 
    t1.Start(); 

    t0.Join(); 
    t1.Join(); 

    Console.ReadLine(); 
} 

public static void Counter(int k, int m) { 
    for(int i = k; i < m; i++) { 
     lock (lockObject) { 
      count++; 
      Console.WriteLine(count + " " + i); 
      if (i == 7) { 
       /* 
       * Code that will kill thread t0 and t1 
       */ 
      } 
     } 
    } 
} 

出力は

1 1 
2 2 
3 10 
4 11 
5 12 
6 13 
7 14 

ような何か誰かがt0とt1の両方を殺すためにどのような提案を持っていなければなりませんか？

Answer 1

フラグ（この場合は「実行」）を使用します。

public static int count = 0; 
private static object lockObject = new object(); 
static bool run = true; 

static void Main(string[] args) { 
    Thread t0 = new Thread(() => Counter(1, 10)); 
    Thread t1 = new Thread(() => Counter(10, 20));   

    t0.Start(); 
    t1.Start(); 

    t0.Join(); 
    t1.Join(); 

    Console.ReadLine(); 
} 

public static void Counter(int k, int m) { 
    for(int i = k; i < m && run; i++) { 
     lock (lockObject) { 
      count++; 
      Console.WriteLine(count + " " + i); 
      if (i == 7) { 
       run = false; 
      } 
     } 
    } 
} 

Answer 2

ManualResetEventをご覧ください。 1つを作成し、Counter-methodのfor-loopの内部でイベントが設定されているかどうかを確認し、そうであればfor-loopを解除して戻ります。 7に達したら、単にイベントを設定します。このイベントはスレッドセーフです。

ところで、大学の宿題のようですが、次回は自分で試してみてください。

public static int count = 0; 
private static object lockObject = new object(); 
private ManualResetEvent finish = new ManualResetEvent(false); 

static void Main(string[] args) { 
    Thread t0 = new Thread(() => Counter(1, 10)); 
    Thread t1 = new Thread(() => Counter(10, 20)); 

    t0.Start(); 
    t1.Start(); 

    t0.Join(); 
    t1.Join(); 

    Console.ReadLine(); 
} 

public static void Counter(int k, int m) { 
    for(int i = k; i < m; i++) { 

     lock (lockObject) { 
      if (finish.waitOne(0)) 
       break; 

      count++; 
      Console.WriteLine(count + " " + i); 
      if (i == 7) 
       finish.set() 
     } 
    } 
} 

Answer 3

MSDN ManualResetEvent.isset（）は何か分かりませんが、Matthiasの答えは正しいように見えます。 isset()〜WaitOne(0)を置き換えると、コードは正常に動作します。

private static int count = 0; 
private static ManualResetEvent finish = new ManualResetEvent(false); 
private static int stopValue = 7; 
private static int syncInterval = 0; //0ms 
private static object lockObject = new object(); 
static void Main(string[] args) 
{ 
    Thread t0 = new Thread(() => Counter(1, 10)); 
    Thread t1 = new Thread(() => Counter(10, 20)); 
    t0.Name = "Thread 1"; 
    t1.Name = "Thread 2"; 

    t0.Start(); 
    t1.Start(); 

    t0.Join(); 
    t1.Join(); 

    Console.ReadKey(); 
} 
public static void Counter(int k, int m) 
{ 
    for (int i = k; i < m; i++) 
    { 
     lock (lockObject) 
     { 
      if (finish.WaitOne(syncInterval)) 
       break; 
      count++; 
      Console.WriteLine($"{count} {i}"); 
      if (count == stopValue) 
      { 
       finish.Set(); 
      } 
     } 
    } 
}