已完成的c#任务再次运行..为什么?

本文关键字:运行 为什么 任务 已完成 | 更新日期: 2023-09-27 18:22:14

我对下面代码的行为有点困惑。我正在开发一个专门的命令行实用程序,用于下载和处理一些文件。我正在尽可能使用c的异步功能。当创建任务并使用Task.WaitAll()时,代码段将按预期运行。等待之后,我有两项任务,这两项任务都标记为已完成。问题是:我试图从任务中获取结果,结果第二次同时运行了两个任务!为什么会这样?如何在不执行第二次任务的情况下读取结果?

    private IEnumerable<Task<FileInfo>> DownloadFiles()
    {
        int fileCount = 1;
        Console.Clear();
        Console.SetCursorPosition(0, 0);
        Console.Write("Download files...");
        yield return DownloadFile(Options.SkuLookupUrl, "SkuLookup.txt.gz", fileCount++, f =>
        {
            return DecompressFile(f);
        });
        yield return DownloadFile(Options.ProductLookupUrl, "ProductList.txt.gz", fileCount++, f =>
        {
            return DecompressFile(f);
        });
    }
    public void Execute()
    {
        var tasks = DownloadFiles();
        Task.WaitAll(tasks.ToArray());
        Console.WriteLine();
        Console.WriteLine("Download(s) completed.  Parsing sku lookup file.");
        FileInfo[] files = tasks.Select(t => t.Result).ToArray(); // <-- triggers a second round of task execution
        ParseSkuLookups(files.SingleOrDefault(f => f.Name.ToLowerInvariant().Contains("skulookup")));
    }

如果相关的话,这里是下载方法:

    private async Task<FileInfo> DownloadFile(string targetUrl, string destinationFile, int lineNumber, Func<FileInfo,FileInfo> callback = null)
    {
        FileInfo fi = new FileInfo(destinationFile);
        if (!Options.NoCleanup || !fi.Exists)
        {
            WebClient client = new WebClient();
            client.DownloadProgressChanged += (s, e) =>
            {
                char spinnerChar;
                switch ((e.ProgressPercentage % 10))
                {
                    case 0: spinnerChar = '|'; break;
                    case 1: spinnerChar = '/'; break;
                    case 2: spinnerChar = '-'; break;
                    case 3: spinnerChar = '|'; break;
                    case 4: spinnerChar = ''''; break;
                    case 5: spinnerChar = '|'; break;
                    case 6: spinnerChar = '/'; break;
                    case 7: spinnerChar = '-'; break;
                    case 8: spinnerChar = ''''; break;
                    default:
                    case 9: spinnerChar = '|'; break;
                }
                lock (ConsoleLockSync)
                {
                    Console.SetCursorPosition(0, lineNumber);
                    Console.WriteLine(String.Format("{0} download: {1}% {2}", 
                        destinationFile, e.ProgressPercentage==100 ? "[Complete]" : spinnerChar.ToString()));
                }
            };
            await client.DownloadFileTaskAsync(new Uri(targetUrl, UriKind.Absolute), destinationFile);
        }
        else if(Options.NoCleanup)
        {
            lock (ConsoleLockSync)
            {
                Console.SetCursorPosition(0, lineNumber);
                Console.WriteLine(String.Format("{0} download: Skipped [No Cleanup]        ", destinationFile));
            }
        }
        fi.Refresh();
        return callback != null ? callback(fi) : fi;
    }

已完成的c#任务再次运行..为什么?

IEnumerableyield return实现时,每次枚举结果时,它都会重新运行函数。Task.WaitAll(tasks.ToArray());中的tasks.ToArray()枚举一次,然后在tasks.Select(t => t.Result).ToArray();中再次枚举。要使其枚举一次,请保留第一个ToArray()调用的结果,然后在整个方法中重复使用该结果。

public void Execute()
{
    var tasks = DownloadFiles();
    var taskArray = tasks.ToArray();
    Task.WaitAll(taskArray);
    Console.WriteLine();
    Console.WriteLine("Download(s) completed.  Parsing sku lookup file.");
    FileInfo[] files = taskArray.Select(t => t.Result).ToArray(); // <-- notice we use taskArray here instead of tasks.
    ParseSkuLookups(files.SingleOrDefault(f => f.Name.ToLowerInvariant().Contains("skulookup")));
}