모든 스레드를 즉시 죽이는 방법

Question

두 개의 스레드를 사용하여 숫자를 계산하는 작은 예제 프로그램을 만들었습니다. 또한 숫자 옆에 두 번째 숫자를 인쇄하므로 어느 번호의 스레드가 인쇄되었는지 확인할 수 있습니다.

이제 내 목표는 두 스레드 중 하나가 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를 살펴보십시오. 하나를 만들고 카운터 메소드의 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(); 
      } 
     } 
    } 
}