2

Есть класс для реализации фтп клиента с синхронизацией.

class FtpFile
    {
        private string md5;
        private string file;
        private string path;
        private string status;

        public string File
        {
            get { return file; }
            set { file = value; }
        }

        public string Status
        {
            get { return status; }
            set { status = value; }
        }

        public string Md5
        {
            get { return md5; }
            set { md5 = value; }
        }

        public string Path
        {
            get { return path; }
            set { path = value; }
        }

Я хочу чтобы при нажатии кнопки в бесконечном цикле шла. Описываю алгоритм

  1. Проверка доступности файла. Если файл никем не юзается, идем дальше

  2. Проверяем md5 файла. Если он отличается, то грузим файл на сервак

    var listFtpFile = new List<FtpFile>();
    FtpFile ftpFile;
    
    for (int i = 0; i < dgv.Rows.Count; i++)
    {
        ftpFile = new FtpFile();
        ftpFile.File = dgv.Rows[i].Cells[1].Value.ToString(); // файл 123.txt
        ftpFile.Path = dgv.Rows[i].Cells[0].Value.ToString(); // путь /
        listFtpFile.Add(ftpFile);
    
    /*      if (Helper.IsFileReady(file))
            {
                var md5 = Helper.CalculateMD5Hash(file);
                if (ftpFile.Md5 != md5)
                {
                    ftpFile.Md5 = Helper.CalculateMD5Hash(file);
                    myFTP myFtp = new myFTP(host, login, password, "/");
                }
            }
    */
     }
    

Теперь стоит вопрос о том как правильно реализовать бесконечный цикл для Parallel.For. Не знаю, может есть лучшая конструкция просто на Thread-ах. Подскажите куда плыть.

1 ответ 1

5
public class ParallelUtils
{
    public static void While(Func<bool> condition, Action body) 
    { 
        Parallel.ForEach(IterateUntilFalse(condition), ignored => body()); 
    }

    private static IEnumerable<bool> IterateUntilFalse(Func<bool> condition) 
    { 
        while (condition()) yield return true; 
    }
}

Используем так:

Func<bool> whileCondFn = () => !_requestStopFlag;
ParallelUtils.While(whileCondFn, delegate()
{

});

Источник: Implementing Parallel While with Parallel.ForEach

Ваш ответ

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

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