被调用函数内部的参数值不同

Question

我正在使用下面的代码在 C# 中创建多个任务：

private static List<Task> _taskList = new List<Task>();
private static ConcurrentQueue<string> cred = new ConcurrentQueue<string>();

private static void TaskMethod1(string usercred)
{
    // I am doing a bunch of operations here, all of them can be replaced with
    // a sleep for 25 minutes.
    // After all operations are done, enqueue again.
    cred.Enqueue("usercred")
}

private static void TaskMethod()
{
    while(runningService)
    {
        string usercred;
        // This will create more than one task in parallel to run,
        // and each task can take up to 30 minutes to finish.
        while(cred.TryDequeue(out usercred))
        {
            _taskList.Add(Task.Run(() => TaskMethod1(usercred)));
        }
    }
}

internal static void Start()
{
    runningService = true;
    cred.enqueue("user1");
    cred.enqueue("user2");
    cred.enqueue("user3");
    Task1 = Task.Run(() => TaskMethod());
}

我在上面的代码中遇到了一个奇怪的行为。通过在_taskList.Add(Task.Run(() => TaskMethod1(usercred))); 行放置一个断点，我每次调用TaskMethod1 时都会检查usercred 的值，并且在调用时它不为空，但在其中一种情况下usercred 的值是null 内部TaskMethod1。我不知道这是怎么发生的。

Answer 1

您正在使用Task.Run，其中您正在使用来自 while 循环的变量。您没有将其传递给任务。因此，当任务执行时，它的值会发生变化。

你应该使用

while (runningService)
{
    string usercred;
    // This will create more than one task in parallel to run,
    // and each task can take upto 30 minutes to finish.
    while (cred.TryDequeue(out usercred))
    {
        _taskList.Add(Task.Factory.StartNew((data) => TaskMethod1(data.ToString()), usercred)
    }
}

Answer 2

您应该 declare 内部 while 循环内的 usercred 变量，以便 Task.Run 内的 lambda 为每个循环捕获一个单独的变量，而不是为所有循环捕获同一个变量。

while(runningService)
{
    while(cred.TryDequeue(out var usercred))
    {
        _taskList.Add(Task.Run(() => TaskMethod1(usercred)));
    }
}

作为旁注，我会考虑使用BlockingCollection 而不是ConcurrentQueue，以便在项目可用之前阻止当前线程，这样我就不必担心无意中创建一个紧密的循环。

Answer 3

以下更改解决了问题。

private static void TaskMethod()
{
    while(runningService)
    {
        string usercred;
        // This will create more than one task in parallel to run,
        // and each task can take up to 30 minutes to finish.
        while(cred.TryDequeue(out usercred))
        {
            var uc = usercred;
            _taskList.Add(Task.Run(() => TaskMethod1(uc)));
        }
    }
}