我的响应式GUI与后台进程的方法正确吗？如果不是，请批评并提出改进意见。特别是，指出哪些代码可能会遇到死锁或竞态条件。
工作线程需要能够被取消并报告其进度。我没有使用BackgroundWorker，因为我看到的所有示例都将Process代码放在表单本身上，而不是一个单独的对象上。我考虑过为BackgroundWorker继承LongRunningProcess，但我认为这会在对象上引入不必要的方法。理想情况下，我希望不需要对进程（"_lrp"）有Form引用，但我不知道如何取消进程，除非我在LRP上有一个事件来检查调用者上的标志，但这似乎过于复杂，甚至可能是错误的。
Windows Form（编辑：将*.EndInvoke调用移动到回调中）
工作线程需要能够被取消并报告其进度。我没有使用BackgroundWorker，因为我看到的所有示例都将Process代码放在表单本身上，而不是一个单独的对象上。我考虑过为BackgroundWorker继承LongRunningProcess，但我认为这会在对象上引入不必要的方法。理想情况下，我希望不需要对进程（"_lrp"）有Form引用，但我不知道如何取消进程，除非我在LRP上有一个事件来检查调用者上的标志，但这似乎过于复杂，甚至可能是错误的。
Windows Form（编辑：将*.EndInvoke调用移动到回调中）
public partial class MainForm : Form
{
MethodInvoker _startInvoker = null;
MethodInvoker _stopInvoker = null;
bool _started = false;
LongRunningProcess _lrp = null;
private void btnAction_Click(object sender, EventArgs e)
{
// This button acts as a Start/Stop switch.
// GUI handling (changing button text etc) omitted
if (!_started)
{
_started = true;
var lrp = new LongRunningProcess();
_startInvoker = new MethodInvoker((Action)(() => Start(lrp)));
_startInvoker.BeginInvoke(new AsyncCallback(TransferEnded), null);
}
else
{
_started = false;
_stopInvoker = new MethodInvoker(Stop);
_stopInvoker.BeginInvoke(Stopped, null);
}
}
private void Start(LongRunningProcess lrp)
{
// Store a reference to the process
_lrp = lrp;
// This is the same technique used by BackgroundWorker
// The long running process calls this event when it
// reports its progress
_lrp.ProgressChanged += new ProgressChangedEventHandler(_lrp_ProgressChanged);
_lrp.RunProcess();
}
private void Stop()
{
// When this flag is set, the LRP will stop processing
_lrp.CancellationPending = true;
}
// This method is called when the process completes
private void TransferEnded(IAsyncResult asyncResult)
{
if (this.InvokeRequired)
{
this.BeginInvoke(new Action<IAsyncResult>(TransferEnded), asyncResult);
}
else
{
_startInvoker.EndInvoke(asyncResult);
_started = false;
_lrp = null;
}
}
private void Stopped(IAsyncResult asyncResult)
{
if (this.InvokeRequired)
{
this.BeginInvoke(new Action<IAsyncResult>(Stopped), asyncResult);
}
else
{
_stopInvoker.EndInvoke(asyncResult);
_lrp = null;
}
}
private void _lrp_ProgressChanged(object sender, ProgressChangedEventArgs e)
{
// Update the progress
// if (progressBar.InvokeRequired) etc...
}
}
后台进程：
public class LongRunningProcess
{
SendOrPostCallback _progressReporter;
private readonly object _syncObject = new object();
private bool _cancellationPending = false;
public event ProgressChangedEventHandler ProgressChanged;
public bool CancellationPending
{
get { lock (_syncObject) { return _cancellationPending; } }
set { lock (_syncObject) { _cancellationPending = value; } }
}
private void ReportProgress(int percentProgress)
{
this._progressReporter(new ProgressChangedEventArgs(percentProgress, null));
}
private void ProgressReporter(object arg)
{
this.OnProgressChanged((ProgressChangedEventArgs)arg);
}
protected virtual void OnProgressChanged(ProgressChangedEventArgs e)
{
if (ProgressChanged != null)
ProgressChanged(this, e);
}
public bool RunProcess(string data)
{
// This code should be in the constructor
_progressReporter = new SendOrPostCallback(this.ProgressReporter);
for (int i = 0; i < LARGE_NUMBER; ++i)
{
if (this.CancellationPending)
break;
// Do work....
// ...
// ...
// Update progress
this.ReportProgress(percentageComplete);
// Allow other threads to run
Thread.Sleep(0)
}
return true;
}
}