5

我有一段代码可以搜索多个第三方 API。我根据搜索条件将搜索分为 2 组。我开始两个搜索，因为每个搜索都非常及时，但是如果第一组搜索结果匹配，我不想等待第二个搜索组完成。所以基本上我所拥有的是：

Dictionary<string, string> result = null;
NameSearchDelegate nameDel = new NameSearchDelegate(SearchByName);
IAsyncResult nameTag = nameDel.BeginInvoke(name, null, null);
if(!string.IsNullOrWhiteSpace(telNum))
{
    result = SearchByTelNum(telNum);//Will return null if a match is not found
}
if(null == result)
{
    result = nameDel.EndInvoke(nameTag);
}
//End the delegate to prevent memory leak
//else
//{
//    nameDel.EndInvoke(nameTag)
//}
return result;

因此，我想在调用 SearchByTelNum 之前启动 SearchByName，以防它找不到匹配项，但是如果它确实找到匹配项，我不想在返回匹配项之前等待 SearchByName 完成。如果我不再需要它的结果，有什么方法可以简单地结束或取消该委托？

4

2 回答 2

1

我能够使用 System.ComponentModel.BackgroundWorker 解决我的问题。我不一定按照预期的方式使用它，但它能够做我需要的事情。所以基本上我的新代码是这样的：

Dictionary<string, string> telResult = null,
                           nameResult = null;

BackgroundWorker bw = new BackgroundWorker();
bw.WorkerSupportsCancellation = true;
bw.DoWork += (obj, e) => nameResult = SearchByName(name, bw);
bw.RunWorkerAsync();

if(!string.IsNullOrWhiteSpace(telNum))
    telResult = SearchByTelNum(telNum);//Will return null if a match is not found

if(telResult != null)
{
    bw.CancelAsync;
    return telResult;
}

bool hasTimedOut = false;
int i = timeOutCount;
while (bw.IsBusy && !hasTimedOut)
{
    System.Threading.Thread.Sleep(500);
    if (0 == --i) hasTimedOut = true;
}

return nameResult;

为了确保没有错误，我必须确保 SearchByName 定期检查 bw.CancellationPending 是否等于 true，并在这种情况下结束该方法。CancelAsync 不会结束工作线程，它只是提醒工作线程调用者线程已取消它。

我也可以简单地使用

while(bw.IsBusy) System.Threading.Thread.Sleep(500)

等待该方法完成，但如果 SearchByName 中发生了一些不好的事情，您最终可能会在无限循环中永远等待。这样，我可以在该方法被认为已超时并且调用者线程继续正常运行之前设置一段时间。在这种情况下，由于我每 0.5 秒检查一次 bw.IsBusy，超时长度等于 timeOutCount / 2 秒。

好的，我想我已经彻底回答了我自己的问题。

于 2013-02-04T15:58:01.620 回答
0

我已经通过定义一个可中止的参数对象来处理这个问题

public class AbortableParameter<T>
{
    public T Parameter { get; private set }
    public bool ShouldAbort { get; set; }
    public AbortableParameter(T parameter)
    {
        Parameter = parameter;
        ShouldAbort = false;
    }
}

只需使用要传递给委托的任何参数创建此类的实例并保留对它的引用；如果委托应该退出，则将其设置为 true。然后，委托需要定期检查ShouldAbort并在它变为 时优雅地退出true。

这是不利的一面，委托人必须定期检查，否则它是否应该中止都没有关系。

也可以让ShouldAbort属性的 set 方法在设置为 true 时杀死委托，但这不是一个优雅的退出，在大多数情况下应该避免——但它确实具有不需要委托轮询的好处。

于 2013-01-30T04:44:55.923 回答