asp.net-mvc - 在 ASP.NET MVC 3 Action 方法中并行运行任务

Question

我在 ASP.NET MVC 3 应用程序中有一个搜索操作，它返回包含给定关键字的建议和标记的建议:

[HttpPost]
public ActionResult Search(string query, int pg = 0)
{
    var keywords = query.Split(new[] { ' ', ',', ';' }, 
        StringSplitOptions.RemoveEmptyEntries);

    var containing = (from s in _readonlySession.All<Suggestion>()
                      from k in keywords
                      where (s.Text.ToLower().Contains(k.ToLower()))
                      orderby s.Text
                      select s).Distinct();

    var tagged = (from t in _readonlySession.All<Tag>()
                  from s in t.Suggestions
                  from k in keywords
                  where t.Text.ToLower().Contains(k.ToLower())
                  orderby s.Text
                  select s).Distinct();

    var model = new SearchViewModel
    {
        Query = query,
        Containing = containing.ToList(),
        Tagged = tagged.ToList()
    };

    return View(model);
}

我认为 containing和 tagged查询可以完美地并行运行。

同时触发这两个查询、等待结果并仅在两个查询完成时返回的最佳方法是什么？

Answer 1

Task Parallels 库是您的最佳选择。来自 Google 的大量信息，但以下是您的实现可能的样子。

[HttpPost]
public ActionResult Search(string query, int pg = 0)
{
    var keywords = query.Split(new[] { ' ', ',', ';' }, 
        StringSplitOptions.RemoveEmptyEntries);

    IEnumerable containing=null;
    Task t1 = Task.Factory.StartNew(() =>
    {
        containing = (from s in _readonlySession.All<Suggestion>()
                        from k in keywords
                        where (s.Text.ToLower().Contains(k.ToLower()))
                        orderby s.Text
                        select s).Distinct().ToList();

    });

    IEnumerable tagged=null;
    Task t2 = Task.Factory.StartNew(() =>
    {
        var tagged = (from t in _readonlySession.All<Tag>()
                        from s in t.Suggestions
                        from k in keywords
                        where t.Text.ToLower().Contains(k.ToLower())
                        orderby s.Text
                        select s).Distinct().ToList();
    });

    t1.Wait();
    t2.Wait();

    var model = new SearchViewModel
    {
        Query = query,
        Containing = containing.ToList(),
        Tagged = tagged.ToList()
    };

    return View(model);
}

请记住，如果您的应用程序收到大量请求，最好不要异步执行查询 - 消耗 2 个额外线程来处理一个请求会占用其他传入请求的资源。如果您的流量很大，或者您的硬件不足，这只会是一个问题。