Создание новой BackgroundWorker для каждой задачи async

Question

Я создаю новый BackgroundWorker каждый раз, когда мне нужно выполнить какую-либо задачу Async и после завершения работы, но я сомневаюсь, что это полностью ее использует, потому что метод Dispose реализован по Системе. ComponentModel.Component

При типичном запуске программы могут быть созданы тысячи из них. Все в порядке, если миллионы из них (чтобы быть в безопасности) создаются или я должен делать это по-другому?

Большая часть работы async - это ввод-вывод, и я не могу использовать async/await, потому что я использую .NET 4 (не могу использовать 4.5).

Я завернул все это в этом методе:

public void AsyncDo(Action Action, Action ActionFinish = null) 
{ 
    using (BackgroundWorker bw = new BackgroundWorker()) { 
     bw.DoWork +=() => Action(); 
     bw.RunWorkerCompleted += (s, e) => 
     { 
      if (ActionFinish != null) 
       ActionFinish(); 
      if (e.Error != null) 
       OnException(e.Error); 
     }; 
     bw.RunWorkerAsync(); 
    } 
} 

Исходя из ответов, я обновил его с

Task t = new Task(action); 
t.Start(); 

Но я получаю ошибку кросс-нить, когда я сделайте actionFinish(), объединив его с action или позвонив по телефону t.ContinueWith(). Это было не так в BGW, это не требовало вызова для RunWorkerCompleted. Я не могу изменить каждый вызов этого метода, чтобы заставить их использовать вызов, что мне делать?

Answer 1

BackgroundWorker специально разработан для обеспечения возможности запуска кода в фоновом режиме относительно потока пользовательского интерфейса, а также обеспечения простой синхронизации с пользовательским интерфейсом.

Если вам нужно выполнить какую-либо асинхронную задачу, просто используйте Task - вот для чего она предназначена. Если у вас нет .NET 4+, вам нужно будет использовать Thread (или лучше, ThreadPool.QueueUserWorkItem), но это еще сложнее (хотя обманчиво просто). Как всегда, http://www.albahari.com/threading/ должны быть отправной точкой при попытке реализовать многопоточность (или асинхронный код вообще) :)

EDIT:

Чтобы получить поведение близко к тому, что у вас было изначально с BackgroundWorker, вы можете просто добавить продолжение для запуска в потоке пользовательского интерфейса:

var task = Task.Factory.StartNew(yourAction); 
task.ContinueWith(yourResultAction, TaskScheduler.FromCurrentSynchronizationContext()); 

Все это сильно типизированных, так что это довольно легко пройти произвольное значение из yourAction задачи (бег на рабочем потоке) в yourResultAction (работает в потоке пользовательского интерфейса). Обратите внимание, что TaskScheduler.FromCurrentSynchronizationContext() должен быть запущен в потоке пользовательского интерфейса, конечно.

Вы можете обернуть это в простую вспомогательную функцию, которая просто возьмет два действия и вернет задачу (либо исходную задачу, либо задачу продолжения, которая зависит от того, что вы хотите с ней делать).

Кроме того, Microsoft.Bcl.Async приносит большую часть .NET 4.5 + s await благость к .NET 4.0 - в конце концов, await все в компилятор, он не нуждается в новой среде выполнения работы. Работа с await намного проще, чем работа с продолжением, особенно при обработке ошибок.

Answer 2

BackgroundWorker и задача - это процессы Windows, поэтому я не знаю, зачем вам обоим. Класс также является процессом, но мне нравится использовать отдельный класс, а не задачу.

Imports System.ComponentModel 
Module Module1 

    Sub Main() 
     Dim backgroundWorker As New MyBackGroundWorker 
     backgroundWorker.Dispose() 
    End Sub 

End Module 
Class MyBackGroundWorker : Implements IDisposable 

    Dim backgroundWorker As New BackgroundWorker 

    Sub Dispose() Implements IDisposable.Dispose 

     Me.Dispose() 
    End Sub 
End Class 

Answer 3

Состояние гонки возникает, когда два или более потоков доступа к общим данным, для записи, в то же время . (Как работать с условиями гонки, рассматривается далее в этой главе в разделе «Синхронизация ».) Если вы попытаетесь обновить пользовательский интерфейс из другого потока, .NET Framework выдает InvalidOperationException, содержащее следующее сообщение: «Перекрестная резьба операция не valid: Control 'ctrlName', доступ к которому осуществляется из потока, отличного от потока, который был создан . "

Чтобы решить эту проблему, измените метод worker_RunWorkerCompleted следующим образом:

void _worker_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e) { 
     if (this.InvokeRequired) { 
      this.Invoke(
       new Action(ActionFinish)); 
     } 
     else { 
      ActionFinish(); 
     } 
    } 

В методе worker_RunWorkerCompleted, теперь проверить свойство InvokeRequired . Это свойство определено в классе Control и как таковое присутствует во всех элементах управления на странице. InvokeRequired имеет значение false, если вы вызываете его из потока пользовательского интерфейса и true в противном случае.

Метод Invoke принимает в качестве первого параметра делегат, то есть любой метод может быть размещен там . Новый вызов конструктора Action() используется для обеспечения того, чтобы вы получили делегат. Если у вашего метода есть другая подпись, вы должны соответствующим образом изменить этот конструктор . Остальные параметры метода Invoke отправляются непосредственно на метод , который вы хотите запустить. Invoke помещает вызов метода в очередь, которая будет подхвачена потоком пользовательского интерфейса.

Лучшее решение?

void worker_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e { this.Dispatcher.Invoke(()=> //statement); } 

Достаточно вызвать метод Dispatcher.Invoke во всех ситуациях. Этот вызов гарантирует, что оператор lambda expression() => // запускается потоком пользовательского интерфейса, независимо от того, из какого потока вызывается этот метод.