0

Имеется button1, при нажатии на который должна запуститься параллельная обработка файлов. Код:

    private async void button1_ClickAsync(object sender, EventArgs e)
    {
            for (int i = 0; i < paths.Count; i++)
            {
                    await Processing(paths[i]);
            }
    }

Сам метод:

public async Task Processing(string path)
    {
        byte[] newFile; //Переменная для записи нового файла
        using (FileStream f = File.OpenRead(path))
        {
            byte[] openFile = new byte[f.Length];
            await f.ReadAsync(openFile, 0, openFile.Length);
            //Обработка файла, в ней же и записываются значения в newFile
        }
        File.Delete(path); //Можно вместо этого изменить FileMode в следующей строке, но пока что не до этого
        using (FileStream f = new FileStream(path, FileMode.Create))
        {
            await f.WriteAsync(newFile, 0, newFile.Length);
        }
        processed++;
        label10.Text = "Обработано файлов: " + processed;
    }

Обрабатывает несколько файлов и сохраняет пустые файлы. Ощущение, что файлы читаются неправильно, либо неправильно записываются. Ошибка в том, что делаю методы параллельно или в асинхронности самих методов? Спасибо.

4
  • 1) Этот код обрабатыевает файлы последовательно. 2) Этот код показан как есть? Не вижу в нем смысла, он берет содержимое файла, читает и его же без каких-либо изменений зарисывает обратно. 3) Параллельно обрабатывать файлы смысла мало, так как диск будет все равно данные выдавать для N файлов с такой же скоростью как и для одного файла. 4) Грубых ошибок в коде не вижу, ну если только я бы написал это всё вместе в 3-4 строки кода. 5) Используется массив - либо файлы очень маленькие, либо вам стоит освоить работу с потоками данных через буфер, а не вычитывать полностью в память.
    – aepot
    Commented 2 нояб. 2021 в 19:37
  • 1
    byte[] openFile = new byte[f.Length]; -> newFile = new byte[f.Length]; ?
    – tym32167
    Commented 2 нояб. 2021 в 19:40
  • @tym32167 точняк, проглядел. :)
    – aepot
    Commented 2 нояб. 2021 в 19:42
  • 1
    @aepot 1) Этот код обрабатыевает файлы последовательно. - таки асинхронно, но не параллельно. П.С. Хотел докопаться, перечитал, а ты таки написал тоже верно.
    – tym32167
    Commented 2 нояб. 2021 в 19:47

1 ответ 1

1

Во-первых, как указали на ошибку, вы читаете файл в массив openFile, а записываете массив newFile, а в нём пусто.

Во-вторых, вот то же самое, только код короче. С выносом обработки данных в отдельный поток, чтобы не вешать приложение. Допустим, обработка данных выполняется ощутимо долго. Допустим, количество байт в записываемом файле такое же, как в прочитанном.

private async Task ProcessFileAsync(string path)
{
    byte[] bytes = await File.ReadAllBytesAsync(path);
    await Task.Run(() => ProcessData(bytes));
    await File.WriteAllBytesAsync(path, bytes);
    processed++;
    label10.Text = "Обработано файлов: " + processed;
}

private void ProcessData(byte[] bytes)
{
    // здесь синхронная обработка данных массива с записью изменений в этот же массив
} 

В-третьих, обработка файлов происходит последовательно, один за другим. Можно сделать параллельно, но это имеет смысл только если чтение и запись файла занимают немного времени по сравнению с обработкой данных.

private async void button1_Click(object sender, EventArgs e)
{
    button1.Enabled = false;
    Task[] tasks = new Task[paths.Count]; 
    for (int i = 0; i < paths.Count; i++)
    {
        tasks[i] = ProcessFileAsync(paths[i]);
    }
    await Task.WhenAll(tasks);
    button1.Enabled = true;
}

Вот теперь обработка полностью будет выполняться действительно параллельно.

Кстати, суффикс ...Async стоит дописывать только к ожидабельным (awaitable) методам, то есть к которым можно применить await. Методы типа async void ожидать нельзя, как следствие и нельзя их признать асинхронными из вызывающего кода.

19
  • 3
    aepot - я просто пришел в Ваш ответ аплодировать стоя! Коротко, ёмко и правильно!
    – S.H.
    Commented 2 нояб. 2021 в 19:59
  • await Task.WhenAll(paths.Select(p=>ProcessFileAsync(p))); ?
    – tym32167
    Commented 2 нояб. 2021 в 20:00
  • 1
    okay, так тоже норм
    – tym32167
    Commented 2 нояб. 2021 в 20:02
  • 1
    @aepot все получилось, спасибо)
    – Varagian
    Commented 3 нояб. 2021 в 10:14
  • 1
    @Varagian ура, а то я уже скриншот приготовил i.imgur.com/NbKiP4l.png
    – aepot
    Commented 3 нояб. 2021 в 10:15

Ваш ответ

Нажимая «Отправить ответ», вы соглашаетесь с условиями пользования и подтверждаете, что прочитали политику конфиденциальности.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.