1

我有一个从 ASP.NET MVC4 网页启动的长时间运行的异步任务。控制器方法如下所示：

[HttpPost]
public ActionResult Index(IndexModel model)
{
    if (ModelState.IsValid)
    {
        try
        {
            model.NotificationRecipient = model.NotificationRecipient.Replace(';', ',');
            ImportConfiguration config = new ImportConfiguration()
            {
                BatchId = model.BatchId,
                ReportRecipients = model.NotificationRecipient.Split(',').Select(c => c.Trim())
            };
            System.Threading.ThreadPool.QueueUserWorkItem(foo => LaunchFileImporter(config, this.HttpContext.ApplicationInstance.Context));
            if (model.RunExport) ThreadPool.QueueUserWorkItem(foo => LaunchFileExporter());
            Log.InfoFormat("Queued the ImportProcessor to process invoices.  Send Notification: {0} Email Recipient: {1}",
                model.SendNotification, model.NotificationRecipient);
            TempData["message"] = "The import processor job has been started.";
            //return RedirectToAction("Index", "Home");
        }
        catch (Exception ex)
        {
            Log.Error("Failed to properly queue the invoice import job.", ex);
            ModelState.AddModelError("", ex.Message);
        }
    }

    var dirInfo = new System.IO.DirectoryInfo(dir);
    model.Files = dirInfo.EnumerateFiles("*.xml").OrderBy(x => x.Name.ToLower());

    return View(model);
}

我的LaunchFileImporter方法如下所示：

private void LaunchFileImporter(ImportConfiguration config, System.Web.HttpContext context)
{
    //the semaphore prevents concurrent running of this process, which can cause contention.
    Log.Trace(t => t("submitter semaphore: {0}", (exporter == null) ? "NULL" : "present."));
    submitter.WaitOne();
    try
    {
        Log.Trace(t => t("Context: {0}", context));
        using (var processor = new ImportProcessor(context))
        {
            processor.OnFileProcessed += new InvoiceFileProcessing(InvoiceFileProcessingHandler);
            processor.OnInvoiceProcessed += new InvoiceSubmitted(InvoiceSubmittedHandler);
            processor.Execute(config);
        }
    }
    catch (Exception ex)
    {
        Log.Error("Failed in execution of the File Importer.", ex);
    }
    submitter.Release();
}

我的 Logger 是一个 Common.Logging private static readonly ILog，并且是为 NLog 配置的。似乎接线正确；至少，我从中得到了相当多的日志。

事情是这样的：在我点击的那一刻System.Threading.ThreadPool.QueueUserWorkItem，应用程序池死亡螺旋变成了无声的死亡，重置应用程序池，重新加载会员提供程序，重新处理 web.config，整个 shebang ......没有 YSOD，网页上没有任何指示……一切都悄悄地爆发了。我得到的最后一个日志条目是Queued the ImportProcessor to process invoices....

我应该注意页面会刷新。被TempData["message"]填充并显示在屏幕上，这让我相信问题发生在异步过程中......但几乎立即发生。由于缺少额外的日志，我假设记录器有问题。

所以我希望有人可以告诉我发生了什么，指出一些记录在案的问题，告诉我我是如何成为一个白痴，或者重现类似错误的东西。

谢谢！

更新

@RichardDeeming 指出上下文信息没有进入生成的线程，这似乎是问题的原因。我仍然没有弄清楚为什么这不起作用，也没有编写跟踪消息，但是一旦我捕获了我需要的上下文部分，IPrincipal, 并使用它而不是上下文对象，它就起作用了.

4

1 回答 1

3

你会得到一个NullReferenceException：

ThreadPool.QueueUserWorkItem(foo => LaunchFileImporter(config, HttpContext.ApplicationInstance.Context));

请求完成后将被HttpContext清理。由于异常是在后台线程上引发的，因此它将关闭整个AppDomain，导致您的应用程序重新启动。

您需要从控制器操作的上下文中捕获相关状态，并在WaitCallback委托中使用该状态：

IPrincipal user = Context.User;
ThreadPool.QueueUserWorkItem(foo => LaunchFileImporter(config, user));

// Or:
// ThreadPool.QueueUserWorkItem(state => LaunchFileImporter(config, (IPrincipal)state);
于 2012-12-10T21:50:37.220 回答