C# zabić wszystkich wątków

Question

mam aplikację, która wywołuje mój DLL z InvokeMember() tak:

Assembly OCA = Assembly.LoadFrom("./Modules/ProcessFiles.dll"); 
Type[] types = OCA.GetTypes(); 
foreach (var type in types) 
{ 
    //MethodInfo[] methods = type.GetMethods(); 
    if (type.Name == "Converter") 
    { 
     var tmpType = type; 
     var obj = Activator.CreateInstance(tmpType); 
     Thread t = new Thread(
      () => 
      tmpType.InvokeMember("Run", BindingFlags.Default | BindingFlags.InvokeMethod, null, obj, 
      null)); 
     t.Start(); 
     break; 
    } 

} 

Moje DLL następnie tworzy nowy wątek i rozpoczyna przetwarzanie. W mojej bibliotece DLL utworzę nowy wątek:

Thread thread = new Thread(
    delegate(){ 
     while(true) 
     { 
      GetFilesInFolder(); 
      Thread.Sleep(120000); 
     } 
    }); 
ne.Start(); 

Celem jest okresowe sprawdzanie folderu. Problem polega na tym, że kiedy zamykam aplikację, która wywołuje moją bibliotekę DLL, proces nie jest zamykany. Czy istnieje sposób na zamknięcie wszystkich wątków?

NB: Nie mogę zmodyfikować aplikacji, mogę tylko modyfikować moją bibliotekę DLL.

Answer 1

Ustaw właściwość IsBackground wątku na true. Spowoduje to zabicie wątku po zakończeniu aplikacji.

Ponadto: Dlaczego nie używasz jednego licznika czasu (lub tylko jednego wątku), który budzi i wyłudza dane. To powinno być bardziej przyjazne dla zasobów.

Answer 2

Czy próbowałeś użyć System.IO.FileSystemWatcher? to powoduje zdarzenia, gdy coś się zmienia w folderze. Wygląda na to, że uprości to twoje rozwiązanie.

Answer 3

Można używać wątek tła wymienionych powyżej lub czasowy:

Timer checkTimer; 
public void StartTimer() 
{ 
    checkTimer = new Timer(s => GetFilesInFolder(), null, 0, 120000); 
} 

Nie zapomnij go wyrzucić.

Answer 4

Jak o wdrożenie bezpiecznych Rezygnacja z here

class RulyCanceler 
{ 
    object _cancelLocker = new object(); 
    bool _cancelRequest; 
    public bool IsCancellationRequested 
    { 
    get { lock (_cancelLocker) return _cancelRequest; } 
    } 

    public void Cancel() { lock (_cancelLocker) _cancelRequest = true; } 

    public void ThrowIfCancellationRequested() 
    { 
    if (IsCancellationRequested) throw new OperationCanceledException(); 
    } 
} 

test

class Test 
{ 
    static void Main() 
    { 
    var canceler = new RulyCanceler(); 
    new Thread (() => { 
         try { Work (canceler); } 
         catch (OperationCanceledException) 
         { 
          Console.WriteLine ("Canceled!"); 
         } 
         }).Start(); 
    Thread.Sleep (1000); 
    canceler.Cancel();    // Safely cancel worker. 
    } 

    static void Work (RulyCanceler c) 
    { 
    while (true) 
    { 
     c.ThrowIfCancellationRequested(); 
     // ... 
     try  { OtherMethod (c); } 
     finally { /* any required cleanup */ } 
    } 
    } 

    static void OtherMethod (RulyCanceler c) 
    { 
    // Do stuff... 
    c.ThrowIfCancellationRequested(); 
    } 
}