2

给定以下代码：

if (!string.IsNullOrEmpty(link1))
{
    string[] link1_ar = link1.Split(sep, StringSplitOptions.None);
    string page1 = link1_ar[1];
    string filter1 = link1_ar[2];
    string code2 = link2_ar[3];
    MyMethod(summary, page1, filter1, code1);
}
if (!string.IsNullOrEmpty(link2))
{
    string[] link2_ar = link2.Split(sep, StringSplitOptions.None);
    string page2 = link2_ar[1];
    string filter2 = link2_ar[2];
    string code2 = link2_ar[3];
    MyMethod(summary, page2, filter2, code2);
}
if (!string.IsNullOrEmpty(link3))
{
    string[] link3_ar = link3.Split(sep, StringSplitOptions.None);
    string page3 = link3_ar[1];
    string filter3 = link3_ar[2];
    string code3 = link3_ar[3];
    MyMethod(summary, page3, filter3, code3);
}


    private void MyMethod(ref string summary, string bid_page, string bid_filter, string bid_code, string bid_silver)
    {
        bla bla bla
    }

我想同时运行三个 MyMethod！
为了达到这个目的，我应该在这些代码中进行哪些更改？

4

2 回答 2

3

假设您的 MyMethod 实际上是线程安全的，那么以下内容应该使用 .Net 4.0 中的 Parallel.ForEach() 方法工作。我正在跟踪 ConcurrentDictionary 中的各个摘要，以便您以后可以在需要时通过链接引用它们。

我还假设您更改了 MyMethod() 以返回摘要。

List<string> links = new List<string>() { link1, link2, link3};

ConcurrentDictionary<string, string> summariesByLink = new ConcurrentDictionary<string, string>();

Parallel.ForEach(links, link => {

  if (!string.IsNullOrEmpty(link))
  {
    string[] link_ar = link.Split(sep, StringSplitOptions.None);
    string page = link_ar[1];
    string filter = link_ar[2];
    string code = link_ar[3];
    string summary = MyMethod( page, filter, code);

    summariesByLink.Add(link, summary);
  }
}
于 2012-12-12T02:55:05.270 回答
1

尝试将每个对 MyMethod 的调用包装在一个任务中，然后等待它们全部完成。

var tasks = new List<Task>();

if (!string.IsNullOrEmpty(link1))
{
    string[] link1_ar = link1.Split(sep, StringSplitOptions.None);
    string page1 = link1_ar[1];
    string filter1 = link1_ar[2];
    string code2 = link2_ar[3];
    var link1task = Task.Run(MyMethod(summary, page1, filter1, code1));
    tasks.Add(link1task);
}
if (!string.IsNullOrEmpty(link2))
{
    string[] link2_ar = link2.Split(sep, StringSplitOptions.None);
    string page2 = link2_ar[1];
    string filter2 = link2_ar[2];
    string code2 = link2_ar[3];
    var link2task = Task.Run(MyMethod(summary, page2, filter2, code2));
    tasks.Add(link2task);
}
if (!string.IsNullOrEmpty(link3))
{
    string[] link3_ar = link3.Split(sep, StringSplitOptions.None);
    string page3 = link3_ar[1];
    string filter3 = link3_ar[2];
    string code3 = link3_ar[3];
    var link3task = Task.Run(MyMethod(summary, page3, filter3, code3));
    tasks.Add(link3task);
}

Task.WaitAll(tasks.ToArray());
于 2012-12-12T01:41:26.287 回答