2016-04-28 57 views
0

我正在嘗試使一個常規函數作爲匿名BackgroundWorker的DoWork事件運行。我遇到的問題是該方法根本沒有運行。目前的代碼,我有如下; -將方法傳遞給BackgroundWorker.DoEvent C#

public class Worker 
{ 
    BackgroundWorker worker; 
    public Worker(Func<bool> action) 
    { 
     worker = new BackgroundWorker(); 
     worker.DoWork += (sender, e) => e.Result = action; 
     worker.RunWorkerCompleted += Worker_RunWorkerCompleted; 
     this.action = action; 
    } 

    private void Worker_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e) 
    { 
     Console.WriteLine("Thread completed : "+ e.Result.ToString()); 
    } 

    public void DoWork() 
    { 
     Console.WriteLine("worker thread: working..."); 
     worker.RunWorkerAsync(); 
     //Wait for worker to complete 
     do { } while (worker.IsBusy); 
    } 
} 

功能是通過這樣的: -

Worker workerObject = new Worker(new Func<bool>(() => methodThatReturnsBool(param1, param2))); 
Thread workerThread = new Thread(workerObject.DoWork); 

workerThread.Start(); 

怎麼可能通過該方法,並將它的後臺工作範圍內操作?

+0

http://stackoverflow.com/questions/3475263/passing-a -method-a-backgroundworker-dowork?rq = 1 – mlg

+0

@mlg已經看到了這個問題。嘗試了這些建議,但他們沒有工作。因此,爲什麼我不得不再次提出這個問題。 –

回答

2

從它的外觀來看,您只是將操作本身作爲結果分配,而不是調用它。

worker.DoWork += (sender, e) => e.Result = action(); 

此外,等待循環可能會導致問題。至少把

do {Thread.Yield();} while (worker.IsBusy); 

在那裏

或者使用清潔劑(無忙等待)的方法:

public class Worker 
{ 
    private BackgroundWorker _worker; 
    private AutoResetEvent _event; 
    private Func<bool> _action; 

    public Worker(Func<bool> action) 
    { 
     _action = action; 
     _event = new AutoResetEvent(false); 
     _worker = new BackgroundWorker(); 
     _worker.DoWork += (sender, e) => 
     { 
      try 
      { 
       e.Result = _action(); 
      } 
      finally 
      { 
       _event.Set(); 
      } 
     }; 
     _worker.RunWorkerCompleted += Worker_RunWorkerCompleted; 
    } 

    private void Worker_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e) 
    { 
     Console.WriteLine("Thread completed : "+ e.Result.ToString()); 
    } 

    public void DoWork() 
    { 
     Console.WriteLine("worker thread: working..."); 
     _worker.RunWorkerAsync(); 
     _event.WaitOne(); 
    } 
}