主页 / 问题 / 1423061
Accepted
tomato-magnet-regulato
Asked:2022-08-23 14:01:11 +0000 UTC2022-08-23 14:01:11 +0000 UTC

异步复制配合progressBar'om

  • 772

其实任务已经完成了一半，我有现成的解决方案，不是没有帮助backgoundWorker:

复制功能：

private void copy_file(string source_, string des)
        {
                FileStream fsOut = new FileStream(des, FileMode.Create);
                FileStream fsIn = new FileStream(source_, FileMode.Open);
                byte[] bt = new byte[1048756];
                int readByte;

                while ((readByte = fsIn.Read(bt, 0, bt.Length)) > 0)
                {
                    fsOut.Write(bt, 0, readByte);
                    backgroundWorker1.ReportProgress((int)(fsIn.Position * 100 / fsIn.Length));
                }
                fsIn.Close();
                fsOut.Close();
        }

做工作：

private void Worker_DoWork(object sender, System.ComponentModel.DoWorkEventArgs e)
        {
            copy_file(server_path + filename, Environment.GetFolderPath(Environment.SpecialFolder.Desktop) + "\\" + filename);
        }

RunWorker 已完成：

private void Worker_RunWorkerCompleted(object sender, System.ComponentModel.RunWorkerCompletedEventArgs e)
        {
            if (e.Error == null)
            {               
                err_msg.Text = "Файл находится на рабочем столе!";
            }
            else
            {
                err_msg.Text = "Произошла ошибка.";
            }
            download_sound.Enabled = true;           
        }

进度改变：

private void Worker_ProgressChanged(object sender, System.ComponentModel.ProgressChangedEventArgs e)
        {
            progressBar1.Value = e.ProgressPercentage;
            err_msg.Text = progressBar1.Value.ToString() + "%";
        }

点击按钮：

Worker.RunWorkerAsync();

上面的方法效果很好，但是当在异步函数中使用这个方法时（比如private async void button_click()），我得到了一个线程排队的效果，嗯......文件被复制 - 放在正确的文件夹中 - 进度条立即填满。我试图通过网络复制，同样的麻烦。但幸运的是，当async你btn外出时它可以工作。

现在说重点：

因为 最初，我的计划是使用async\await方法，我切换到这种文件复制：

public async Task CopyFilesAsync(StreamReader Source, StreamWriter Destination)
        {
            char[] buffer = new char[0x1000];
            int numRead;
            while ((numRead = await Source.ReadAsync(buffer, 0, buffer.Length)) != 0)
            {
                await Destination.WriteAsync(buffer, 0, numRead);
            }
        }

_

public async Task CopyFile(string startDirectoy, string endDirectory)
        {
            using (StreamReader SourceReader = File.OpenText(startDirectoy))
            {
                using (StreamWriter DestinationWriter = File.CreateText(endDirectory))
                {
                    await CopyFilesAsync(SourceReader, DestinationWriter);
                    SourceReader.Close();
                    DestinationWriter.Close();
                }
            }
        }

我只是不知道如何让progressBar 执行我的任务。我也无法到达 StreamReader.Position 使用：

progressBar1.Value=(int)((StreamReader.BaseStream.Position/StreamReader.BaseStream.Length)*100);

我没有成功。ProgressBar 与一切分开为我工作>< 如果您有一些提示，请给他们，我将非常感激！

在此处输入图像描述

c# winforms

1 个回答

  1. Best Answer

    我有一个下载文件的例子，为什么不重写它来复制

    • 异步复制文件
    • 通过单击取消按钮，您可以停止复制
    • button1- 复制按钮，button2- 取消按钮，progressBar1- 进度条
    • 使用 IProgress 接口和 Progress 类实现了一个进度报告
    public partial class Form1 : Form
{
    public Form1()
    {
        InitializeComponent();
        button2.Enabled = false;
    }

    // Токен отмены служит для прерывания работы копирования в любой момент
    private CancellationTokenSource _cts;

    private async Task CopyFileAsync(string srcPath, string dstPath, IProgress<int> status, CancellationToken token)
    {
        const int bufferLength = 16384;

        using FileStream src = File.OpenRead(srcPath);
        using FileStream dst = File.Create(dstPath);
        long currentPosition = 0;
        long contentLength = src.Length;
        int progress = -1;
        int oldProgress;
        byte[] buffer = new byte[bufferLength];
        int bytesReceived;
        while ((bytesReceived = await src.ReadAsync(buffer, 0, bufferLength, token).ConfigureAwait(false)) > 0)
        {
            await dst.WriteAsync(buffer, 0, bytesReceived, token).ConfigureAwait(false);

            currentPosition += bytesReceived;
            oldProgress = progress;
            progress = (int)(currentPosition * 100 / contentLength);
            // так как значение от 0 до 100, нет особого смысла повтороно обновлять интерфейс, если значение не изменилось.
            if (oldProgress != progress)
            {
                status?.Report(progress);
            }
        }
    }

    private async void button1_Click(object sender, EventArgs e)
    {
        if (_cts != null)
            return;
        button1.Enabled = false;
        button2.Enabled = true;

        using (_cts = new CancellationTokenSource())
        {
            try
            {
                await CopyFileAsync("file1.txt", "file2.txt", new Progress<int>(v => { progressBar1.Value = v; }), _cts.Token);
            }
            catch (OperationCanceledException) { } // была отмена, ничего не делать
            catch (Exception ex)
            {
                MessageBox.Show(ex.ToString(), ex.GetType().Name);
            }
            progressBar1.Value = 0;
        }
        _cts = null;

        button1.Enabled = true;
        button2.Enabled = false;
    }

    private void button2_Click(object sender, EventArgs e)
    {
        _cts?.Cancel();
    }
}

    考虑到winform进度条的慢动画来更新进度

    private async Task CopyFileAsync(string srcPath, string dstPath, IProgress<int> status, CancellationToken token)
{
    const int bufferLength = 16384;

    using FileStream src = File.OpenRead(srcPath);
    using FileStream dst = File.Create(dstPath);
    long currentPosition = 0;
    long contentLength = src.Length;
    int progress = -1;
    int oldProgress;
    byte[] buffer = new byte[bufferLength];
    int bytesReceived;

    long elapsed = 0;
    var sw = Stopwatch.StartNew();

    while ((bytesReceived = await src.ReadAsync(buffer, 0, bufferLength, token).ConfigureAwait(false)) > 0)
    {
        await dst.WriteAsync(buffer, 0, bytesReceived, token).ConfigureAwait(false);

        currentPosition += bytesReceived;
        oldProgress = progress;
        progress = (int)(currentPosition * 100 / contentLength);
        
        // 1 / 30 = 0.033 - 30 кадров в секунду
        if (oldProgress != progress && (progress == 100 || sw.ElapsedMilliseconds - 33 > elapsed))
        {
            status?.Report(progress);
            elapsed = sw.ElapsedMilliseconds;
        }
    }
}

    @PavelMayorov 关于立即开始在线程池中复制的建议可以这样实现

    IProgress<int> status = new Progress<int>(v => { progressBar1.Value = v; });
await Task.Run(() => CopyFileAsync("file1.txt", "file2.txt", status, _cts.Token));
    • 1

相关问题