使用不同的数据c进行多个相同的异步任务调用＃

我有一个列表，其中包含一些文档（为了简化字符串）。现在这个列表正在慢慢填充。我想要做的是当列表的大小达到20时，我想调用另一个函数，它将在不停止主方法的情况下异步地打印这些字符串。很多搜索后，我设法这段代码放在一起使用不同的数据c进行多个相同的异步任务调用＃

public void DoStuff() 
{ 
    Class1 p = new Class1(); 
    List<string> list = new List<string> { }; 
    var TList = new List<Task>(); 
    int i = 0; 
    while (i < 90) 
    { 
     list.Add(i.ToString()); 
     if (list.Count == 20) 
     { 
      Console.WriteLine("List contents when calling: " + list[0]); 
      TList.Add(Task.Run(() => publishDoc(list))); 
      list.Clear(); 
     } 
     i++; 
    } 
    if (list.Count != 0) 
    { 
     TList.Add(Task.Run(() => publishDoc(list))); 
    } 
    Task.WhenAll(TList).Wait(); 
    Console.WriteLine("Done DoStuff"); 
} 

public async Task publishDoc(List<string> docs) 
{ 
    Console.WriteLine(iter++ + " " + docs[0]); 
    await Task.Run(() => Thread.Sleep(1000)); 
    foreach (var val in docs) 
    { 
     Console.Write(val + " "); 
    } 
    Console.WriteLine(); 
}

这是我得到的输出

List contents when calling: 0 
List contents when calling: 20 
List contents when calling: 40 
List contents when calling: 60 
1 80 
3 80 
0 80 
2 80 
4 80 
80 80 80 80 81 82 83 84 85 86 87 88 89 
81 82 83 84 85 86 87 88 89 
81 82 83 84 85 86 87 88 89 
81 82 83 84 85 86 87 88 89 
80 81 82 83 84 85 86 87 88 89 
Done DoStuff 
Done Main

我想不通为什么它是只打印最后传递的数据，即为什么通过的列表被覆盖。现在，如果我这样做

public void DoStuff() 
{ 
    Program2 p = new Program2(); 
    List<string> list = new List<string> { }; 
    int i = 0; 
    while (i < 90) 
    { 
     list.Add(i.ToString()); 
     if (list.Count == 20) 
     { 
      Console.WriteLine("List contents when calling: " + list[0]); 
      var tasks = publishDoc(list); 
      if (tasks.Result == "Done") 
      { 
       Console.WriteLine("Done " + list[0]); 
      } 
      list.Clear(); 
     } 
     i++; 
    } 
    if (list.Count != 0) 
    { 
     var tasks = publishDoc(list); 
     if (tasks.Result == "Done") 
     { 
      Console.WriteLine("Done " + list[0]); 
     } 
    } 
    Console.WriteLine("Done DoStuff"); 
} 

public async Task<string> publishDoc(List<string> docs) 
{ 
    Console.WriteLine(iter++ + " " + docs[0]); 
    foreach (var val in docs) 
    { 
     Console.Write(val + " "); 
    } 
    Console.WriteLine(); 
    return await Task.Run(() => "Done"); 
}

我得到这个输出

List contents when calling: 0 
0 0 
0 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 
Done 0 
List contents when calling: 20 
1 20 
20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 
Done 20 
List contents when calling: 40 
2 40 
40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 
Done 40 
List contents when calling: 60 
3 60 
60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 
Done 60 
4 80 
80 81 82 83 84 85 86 87 88 89 
Done 80 
Done DoStuff 
Done Main

这是给正确的输出，但同步做，我不想要的。请提前帮助和感谢。

来源

2017-09-13 Makarov

1.忘记你的第二种方法。 2. list.Clear（）;' - 你认为这会做什么？它清除刚刚通过任务参考的列表。 – Fildor

你的第一个列表几乎是正确的，但是传递了对同一个列表实例的引用。而不是'list.Clear（）;'use'list = new List （）;' –

这是一个在C＃中使用线程的常见问题。假设您的主要任务已经在Method中进行了所有准备工作，所以您在Task.Run（）中的lambda将只获得80 <。如果您使用线程，则可以使用ParameterizedThreadStart，它立即接受该变量。不幸的是，我不知道如何用任务解决这个问题。 – Noren

你必须做这样的，因为在循环它指向每一个可能导致问题的时间列表的同一个实例，所以我建议你创建表的副本，将其传递给函数publishDoc

while (i < 90) 
    { 
     list.Add(i.ToString()); 
     if (list.Count == 20) 
     { 
      List<string> copy = list.ToList(); 
      Console.WriteLine("List contents when calling: " + copy[0]); 
      TList.Add(Task.Run(() => publishDoc(copy))); 
      list.Clear(); 
     } 
     i++; 
    }

参见前这个答案也是：Starting Tasks In foreach Loop Uses Value of Last Item

来源

2017-09-13 12:29:44

使用不同的数据c进行多个相同的异步任务调用＃

回答

相关问题