Как мне кажется, то задача содержит противоречие: нельзя "не использовать переменную с side-эффектом" изменить поведение, когда одна из функций крутися в бесконечном цикле.
В этом случае нужно некоторое разделяемое поведение, через которое эта функция сможет получить информацию о том, какую логику использовать.
Один вариант решения - это шаренная потокобезопасная переменная. Это может быть еще одна таска, это может быть любая другая переменная, позволяющая читать и писать себя атомарно: например, volatile переменная ссылочного типа.
Вот один из вариантов на основе таски:
using System;
using System.Threading;
using System.Threading.Tasks;
class Notifier
{
private static Task<bool> taskThatMeansSomething = Task.FromResult(true);
static async Task SendingAsync(CancellationToken cancellationToken)
{
while (!cancellationToken.IsCancellationRequested)
{
bool flag = await taskThatMeansSomething;
if (flag)
{
Console.WriteLine("Flag is true. Doing one thing");
}
else
{
Console.WriteLine("Flag is false. Doing one stuff");
}
await Task.Delay(500, cancellationToken);
}
}
static async Task Observable(CancellationToken cancellationToken)
{
bool result = false;
while (!cancellationToken.IsCancellationRequested)
{
Console.WriteLine($"Changing the flag to {result}");
taskThatMeansSomething = Task.FromResult(result);
result = !result;
await Task.Delay(1000, cancellationToken);
}
}
static void Main()
{
var cancellationTokenSource = new CancellationTokenSource(TimeSpan.FromSeconds(5));
Task sendingTask = Task.Factory.StartNew(
async () => await SendingAsync(cancellationTokenSource.Token),
TaskCreationOptions.LongRunning);
Task observeTask = Task.Factory.StartNew(
async () => await Observable(cancellationTokenSource.Token),
TaskCreationOptions.LongRunning);
Console.WriteLine("Waiting 5 seconds...");
Task.WaitAll(sendingTask, observeTask);
Console.WriteLine("Done! Press \"Enter\" to exit.");
Console.ReadLine();
}
}
Вывод:
Waiting 5 seconds...
Flag is true. Doing one thing
Changing the flag to False
Done! Press "Enter" to exit.
Flag is false. Doing one stuff
Flag is false. Doing one stuff
Changing the flag to True
Flag is true. Doing one thing
Changing the flag to False
Flag is false. Doing one stuff
Flag is false. Doing one stuff
Flag is false. Doing one stuff
Changing the flag to True
Flag is true. Doing one thing
Flag is true. Doing one thing
Changing the flag to False
Flag is false. Doing one stuff
Ну и там несколько моментов:
- Таски нужно запускать через
TaskFactory.StartNew
и указывать, что они долгие (поскольку они долгие)
- Можно и даже желательно, прикрутить graceful cancellation через
CancellationTokenSource
и CancellationToken
.
- Разумно использовать стандартную для C# идиому именования.
- Разумно сделать long running методы возвращающими
Task
.
Вместо шаренной переменной taskThatMeansSomething
можно подумать в сторону того же TPL Dataflow, когда в зависимости от изменения входных данных будет запускаться разные блоки, которые отвечают за отправку данных в одном или в другом режиме.
Вот тогда можно будет полноценно уйти от разделяемого состояния в сторону более actor-based parallelism-а. Если интересно, то я могу набросать этот вариант тоже.