执行异步调用的 Web 服务

Question

我有一个 Web 服务方法 FetchNumber()，它从数据库中获取一个数字，然后将其返回给调用者。但在将号码返回给调用者之前，它需要将此号码发送到另一个服务，因此实例化并运行BackgroundWorker，其工作是将这个号码发送到另一个服务。

public class FetchingNumberService : System.Web.Services.WebService
{
    [WebMethod]
    public int FetchNumber() 
    {
        int value = Database.GetNumber();
        AsyncUpdateNumber async = new AsyncUpdateNumber(value);
        return value;
    }
}

public class AsyncUpdateNumber
{
    public AsyncUpdateNumber(int number)
    {
        sendingNumber = number;

        worker = new BackgroundWorker();
        worker.DoWork += asynchronousCall;
        worker.RunWorkerAsync();
    }

    private void asynchronousCall(object sender, DoWorkEventArgs e)
    {
        // Sending a number to a service (which is Synchronous) here
    }

    private int sendingNumber;
    private BackgroundWorker worker;

}

我不想在将此号码发送到另一个服务时阻止 Web 服务 (FetchNumber())，因为这可能需要很长时间，并且调用者并不关心将该号码发送到另一个服务。呼叫者希望尽快返回。

FetchNumber() 创建后台工作程序并运行它，然后完成（当工作程序在后台线程中运行时）。我不需要后台工作人员的任何进度报告或返回值。这更像是一个“一劳永逸”的概念。

我的问题是这样的。由于 Web 服务对象是在每次方法调用时实例化的，因此当被调用的方法（本例中为 FetchNumber()）完成，而它初始化并运行的后台工作线程仍在运行时，会发生什么情况？

后台线程会发生什么？ GC什么时候收集服务对象？这是否会阻止后台线程正确执行到底？后台线程还有其他副作用吗？

感谢您的任何意见。

Answer 1

从我从您的代码中看到的情况来看，我想说的是，当后台工作人员和 AsyncUpdateNumber 类的实例相互引用时，它们都不会被收集，并且没有代码可以破坏此循环引用。

循环引用是由引用BackgroundWorker 的AsyncUpdateNumber 类创建的，并向BackgroundWorker 注册一个事件，创建对AsyncUpdateNumber 类实例的引用。

那么你能做什么......考虑使用以下选项之一来代替BackgroundWorker：

1. 使用线程。
2. 使用开始调用。
3. 使用线程池。

示例 1：

var thread = new Thread(new ParameterizedThreadStart((v) => { /* do stuff */ }));
thread.Start(value);

示例 2：

var func = new Action<int>(v => { /* do stuff */ });
func.BeginInvoke(value, null, null);

示例 3：

var threadProc = new Action<object>(v => { /* do stuff - note v is of tyoe object */ });
ThreadPool.QueueUserWorkItem(new WaitCallback(threadProc));

编辑：

回答您的问题来自原始帖子：执行线程的方法始终运行直到完成，无论声明它的方法是否退出。即使上面的匿名方法也会运行直到完成。这里应用的概念称为闭包（AFAIK），在匿名方法的情况下，它甚至使所有引用的变量保持活动状态，即使它们没有在方法本身中声明。

但是，您的类是循环引用的一个主要示例，只有在应用程序过程完成后才会回收该引用。这是 .NET 中更微妙的事情之一，即使在托管系统中，也可能导致内存泄漏......事件创建强引用。

虽然，在单个调用的情况下，这不会造成任何问题，但一旦您多次调用，它可能确实会成为问题。

Answer 2

将单个 Web 方法重写

[WebMethod]
public int FetchNumber() 
{
    int value = Database.GetNumber();
    AsyncUpdateNumber async = new AsyncUpdateNumber(value);
    return value;
}

为两个异步委托：

public delegate AsyncUpdateNumber GetAsyncUpdateNumber(object state, int value);

[WebMethod]
public IAsyncResult BeginFetchNumber(AsyncCallback cb, object state) 
{
    int value = Database.GetNumber();
    AsyncUpdateNumber async = new AsyncUpdateNumber(value);
    GetAsyncUpdateNumber getAsyncUpdateNumber = new GetAsyncUpdateNumber(async.DoLongRunningThing);

    return getAsyncUpdateNumber.BeginInvoke(state, cb, getAsyncUpdateNumber);
}

[WebMethod]
public int EndFetchNumber(IAsyncResult res) 
{
    GetAsyncUpdateNumber getAsyncUpdateNumber = (GetAsyncUpdateNumber)res.AsyncState;

    return getAsyncUpdateNumber.EndInvoke(res);
}

它们将显示为名为 FetchNumber() 的单个 Web 方法。 BeginFetchNumber() 中的 BeginInvoke() 将异步执行。我必须在 AsyncUpdater 中编写一个名为 DoLongRunningThing 的方法，以便委托执行。将您需要从构造函数异步完成的任务移至此新方法中。希望这有帮助。