Для задания мониторинга вполне подходит Task
. Вы можете, вероятно, даже не выделять под него отдельный поток.
var cts = new CancellationTokenSource();
var monitoringTask = Monitoring(cts.Token);
// ... дожидаемся конца
cts.Cancel();
await monitoringTask;
async Task Monitoring(CancellationToken ct)
{
TimeSpan pollingPause = TimeSpan.FromSeconds(1);
try
{
while (!ct.IsCancellationRequested)
{
await Task.Delay(pollingPause, ct);
// проверить изменения данных и отправить результат
}
}
catch (OperationCanceledException)
{
}
}
А вот для обмена данными между заданиями вам нужна какая-нибудь реализация producer/consumer. Например, вот тут описывается вариант с BlockingCollection<T>
или (если хотите async-интерфейс) BufferBlock<T>
.
async Task Monitoring(CancellationToken ct, BufferBlock<Data> channel)
{
TimeSpan pollingPause = TimeSpan.FromSeconds(1);
try
{
while (!ct.IsCancellationRequested)
{
await Task.Delay(pollingPause, ct);
var data = await Task.Run(() => CheckNewData(ct), ct);
if (data == null)
continue;
await channel.SendAsync(data, ct);
}
}
catch (OperationCanceledException)
{
}
finally
{
channel.Complete();
}
}
Ещё подошло бы решение с Reactive Extensions, которые как раз и представляют собой push-поток данных. Но у них достаточно высокий порог входа, так что я бы не рассматривал их для первой версии архитектуры.