异步复制大文件，同时向进度条报告进度（示例？）

Question

我需要复制一些大文件并通过进度条向 UI 报告进度。

我买了"C# 5.0 in a Nutshell"。我在第 597 页。我一直在阅读有关并行编程的内容。我试图根据本书中的一些示例来完成我认为非常简单的事情，但我真的很挣扎。一定是我的理解有一些差距。这就是我发布这个问题的原因。

我调查了后台工作人员，但在尝试取得进展时发现自己运行遇到了跨线程编译器错误。

我研究过异步命令，但发现自己误解了 lambda 表达式。那，或者如何通过单击按钮实际异步执行任务的代码，同时仍将进度报告回 UI 线程。

我已经在 MSDN、codeproject 上倾注了许多现有的 questions/answers，在这里我自己问了几个问题，并让他们投了反对票。我只需要一个简单的例子，我可以全神贯注，我会顺利进行的。

我相信我的答案是异步的，Task.Run、File.Copy（也许是 StreamReader/StreamWriter 类）和 IProgress。我在两周的研究和反复试验中发现的问题/答案要么不完整，要么对于某些给定场景来说过于宽泛/过于具体。

我只需要一个带有进度条的 UI 工作示例，以及一个在新线程中执行代码以复制一组大文件（或仅一个大文件）并返回报告的按钮进步。从那里，我可以玩它并根据我的需要调整它并加深我的整体理解。

代码改编自 Clint 的回答，但仍未正确更新进度

此改编在异步任务中复制文件，但仅在复制文件后才将进度从 0 更新为 100%。因为我正在处理大文件，所以基于文件数量的处理进度是不够的。

到目前为止，我没有发现或尝试过在更新大文件的字节进度 %-age 的同时异步执行复制的地址。

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Threading.Tasks;
using System.IO;

namespace CopyProgressWorking
{
    public partial class Form1 : Form
    {
        public Form1()
        {
            InitializeComponent();

            string srcFile = @"C:\temp\BigFile.txt";
            string dstFile = @"C:\temp\temp2\BigFile.txt";
            button1.Click += (s, e) => DoCopy(srcFile, dstFile);
        }

        public async Task CopyFiles(Dictionary<string, string> files, Action<int> progressCallback)
        {
            for (var x = 0; x < files.Count; x++)
            {
                var item = files.ElementAt(x);
                var from = item.Key;
                var to = item.Value;

                using (var outStream = new FileStream(to, FileMode.Create, FileAccess.Write, FileShare.Read))
                {

                    using (var inStream = new FileStream(from, FileMode.Open, FileAccess.Read, FileShare.Read))
                    {

                        long size = inStream.Position;
                        Console.WriteLine("Filesize is {0}", size);
                        await inStream.CopyToAsync(outStream);

                    }
                }

                progressCallback((int)((x + 1) / files.Count) * 100);
            }
        }

        public async void DoCopy(string srcFile, string dstFile)
        {
            label1.Text = "Copying " + srcFile;
            await CopyFiles(new Dictionary<string, string>
            {
                {srcFile, dstFile}
            },
            prog =>
            {
                Invoke((MethodInvoker)delegate {
                    progressBar1.Value = prog;
                    if (prog >= 100)
                    {
                        label1.Text = "Copy complete!";
                    }
                });
            });
        }
    }
}

Answer 1

这应该可以帮助您入门：

public static class Copier
{
    public static async Task CopyFiles(Dictionary<string,string> files, Action<int> progressCallback)
    {
        for(var x = 0; x < files.Count; x++)
        {
            var item = files.ElementAt(x);
            var from = item.Key;
            var to = item.Value;

            using(var outStream = new FileStream(to, FileMode.Create, FileAccess.Write, FileShare.Read))
            {
                using(var inStream = new FileStream(from, FileMode.Open, FileAccess.Read, FileShare.Read))
                {
                    await inStream.CopyToAsync(outStream);
                }
            }

            progressCallback((int)((x+1)/files.Count) * 100);
        }
    }
}

public class MyUI
{
    public MyUI()
    {
        copyButton.Click += (s,e) => DoCopy();
    }

    public async void DoCopy()
    {
        await Copier.CopyFiles(new Dictionary<string,string>
        {
            {"C:\file1.txt", "C:\users\myuser\desktop\file1.txt"},
            {"C:\file2.txt", "C:\users\myuser\desktop\file2.txt"}
        }, prog => MyProgressBar.Value = prog);
    }
}

这是手写的，没有 visual studio，因此可能存在一些问题（拼写等）。

核心概念是：

使用async/await进行异步编程
使用匿名方法 (lambda) 回调报告方法的进度

基本上这段代码所做的是：

使用字典表示要复制的文件位置（当前和新）
遍历每一个并使用文件流和异步复制功能执行复制
通过回调报告整体进度

示例 class "MyUI" 只是 winforms 或 WPF window 的一个非常精简的版本，带有一个启动它的按钮（在点击事件处理程序中) 和一个进度条。

几点注意事项

无需启动新线程，您可以让 TPL（任务并行化库）为您处理调度，尽管此处示例中的所有代码通常都在 UI 线程上运行反正。这不是问题，因为 async/await "magic" 确保 UI 线程在复制操作期间不被阻塞。

IProgress 非常适合更通用的机制，您需要从调用层次结构中深入报告，如果您只向上一级（如我的示例），一个简单的回调就足够了。

使用字典来简单说明问题，实际上您可能想使用 IEnumerable<Tuple<string,string>> 或 IEnumerable<MyTypeHere> 来表示所需的操作。

超级基本的逐字节复制

// Assuming you've got a from and to file stream open
// here is some hand-written pseudocode (C# style) to show the basic concept
foreach(var file in files)
{
    var from = OpenFromStream(file.From);
    var to = OpenFromStream(file.To);

    var lengthOfFile = from.Length;
    for(x = 0; x < lengthOfFile; x++)
    {
        to.WriteByte(from.ReadByte());
        progress((int)(x / lengthOfFile) * 100);
    }
}

这里有一些超级简单的伪代码来说明逐字节复制和报告文件进度的基础知识。

不要忘记处理流（在关闭前刷新输出流是个好主意）
如果您想以更好的方式执行此操作，通过缓冲区读取数据块是一个不错的方法，有很多关于如何执行此操作的教程。

异步复制大文件，同时向进度条报告进度（示例？）

Asynchronously copy large files while reporting progress to a progress bar (example?)

c#

multithreading

asynchronous

system.io.file

几点注意事项