C# Шаблон проектирования для периодов c выполнение нескольких потоков - PullRequest
Новая
       31

C# Шаблон проектирования для периодов c выполнение нескольких потоков

2 голосов
/ 19 февраля 2020

У меня есть ниже требование в моем C# Windows Сервисе.

  1. При запуске Service он выбирает коллекцию данных из базы данных и сохраняет ее в памяти.
  2. Иметь бизнес-логику c, которая будет периодически выполняться из 3 разных потоков.
  3. Каждый поток будет выполнять одну и ту же бизнес-логику c с различным подмножеством данных из набора данных, упомянутого в шаге 1. Каждый поток будет выдавать разные наборы результатов.
  4. Все 3 потока будут работать периодически если какое-либо изменение произошло со сбором данных.

Когда какой-либо клиент обращается к службе, служба должна иметь возможность вернуть статус выполнения потока.

Я знаю, C# имеет различные механизмы для реализации выполнения периодов c. Таймеры, Потоки со Сном, Событие Eventwaithandle и т. Д., Я пытаюсь понять, какой механизм потоков или шаблон проектирования лучше всего подходит для этого требования?

Ответы [ 2 ]

1 голос
/ 19 февраля 2020

Более современный подход - это использование задач, но взгляните на принципы 

namespace Test {

public class Program {

    public static void Main() {

        System.Threading.Thread main = new System.Threading.Thread(() => new Processor().Startup());
        main.IsBackground = false;
        main.Start();
        System.Console.ReadKey();
    }
}

public class ProcessResult { /* add your result state */ }

public class ProcessState {

    public ProcessResult ProcessResult1 { get; set; }
    public ProcessResult ProcessResult2 { get; set; }
    public ProcessResult ProcessResult3 { get; set; }
    public string State { get; set; }
}

public class Processor {

    private readonly object _Lock = new object();
    private readonly DataFetcher _DataFetcher;
    private ProcessState _ProcessState;

    public Processor() {
        _DataFetcher = new DataFetcher();
        _ProcessState = null;
    }

    public void Startup() {
        _DataFetcher.DataChanged += DataFetcher_DataChanged;
    }

    private void DataFetcher_DataChanged(object sender, DataEventArgs args) => StartProcessingThreads(args.Data);

    private void StartProcessingThreads(string data) {

        lock (_Lock) {
            _ProcessState = new ProcessState() { State = "Starting", ProcessResult1 = null, ProcessResult2 = null, ProcessResult3 = null };

            System.Threading.Thread one = new System.Threading.Thread(() => DoProcess1(data)); // manipulate the data toa subset 
            one.IsBackground = true;
            one.Start();

            System.Threading.Thread two = new System.Threading.Thread(() => DoProcess2(data)); // manipulate the data toa subset 
            two.IsBackground = true;
            two.Start();

            System.Threading.Thread three = new System.Threading.Thread(() => DoProcess3(data)); // manipulate the data toa subset 
            three.IsBackground = true;
            three.Start();
        }
    }

    public ProcessState GetState() => _ProcessState;

    private void DoProcess1(string dataSubset) {
        // do work 
        ProcessResult result = new ProcessResult(); // this object contains the result
        // on completion
        lock (_Lock) {
            _ProcessState = new ProcessState() { State = (_ProcessState.State ?? string.Empty) + ", 1 done", ProcessResult1 = result, ProcessResult2 = _ProcessState?.ProcessResult2, ProcessResult3 = _ProcessState?.ProcessResult3 };
        }
    }

    private void DoProcess2(string dataSubset) {
        // do work 
        ProcessResult result = new ProcessResult(); // this object contains the result
        // on completion
        lock (_Lock) {
            _ProcessState = new ProcessState() { State = (_ProcessState.State ?? string.Empty) + ", 2 done", ProcessResult1 = _ProcessState?.ProcessResult1 , ProcessResult2 = result, ProcessResult3 = _ProcessState?.ProcessResult3 };
        }
    }

    private void DoProcess3(string dataSubset) {
        // do work 
        ProcessResult result = new ProcessResult(); // this object contains the result
        // on completion
        lock (_Lock) {
            _ProcessState = new ProcessState() { State = (_ProcessState.State ?? string.Empty) + ", 3 done", ProcessResult1 = _ProcessState?.ProcessResult1, ProcessResult2 = _ProcessState?.ProcessResult2, ProcessResult3 = result };
        }
    }
}

public class DataEventArgs : System.EventArgs {

    // data here is string, but could be anything -- just think of thread safety when accessing from the 3 processors
    private readonly string _Data;

    public DataEventArgs(string data) {
        _Data = data;
    }

    public string Data => _Data;
}

public class DataFetcher {
    //  watch for data changes and fire when data has changed
    public event System.EventHandler<DataEventArgs> DataChanged;
}

}

0 голосов
/ 19 февраля 2020

Самое простое решение - определить запланированные логики c в стиле Task Method() и выполнить их, используя Task.Run(), в то время как в основном потоке просто дождитесь окончания выполнения sh, используя Task.WaitAny(). Если задача завершена, вы можете снова вызвать Task.WaitAny, но вместо выполненной задачи вы наберете Task.Delay(timeUntilNextSchedule). Таким образом, задачи не блокируют основной поток, и вы можете избежать вращения процессора, просто чтобы подождать. В целом, вы можете избежать непосредственного управления в современном. NET

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

...