Перенос использования .GetAwaiter().GetResult() в лямбда-выражении на асинхронный ⇐ C#

[Anonymous]

Учитывая этот ConcurrentDictionary:

Код: Выделить всё

private readonly ConcurrentDictionary _lazyDictionary = new();

У меня есть класс-оболочка, который обеспечивает индивидуальный доступ к словарю...
Один из методов — AddOrUpdate, где я использую перегрузку для передачи в Func для добавления или обновления словаря:

Код: Выделить всё

public TValue AddOrUpdate(TKey key, Func valueCreator, Func valueUpdater)
{
return _lazyDictionary.AddOrUpdate(key,
_ => new(valueCreator),
(_, existingLazyValue)
=> new(() => valueUpdater(existingLazyValue.Value).GetAwaiter().GetResult())).Value;
}

Как мы видим, функция valueUpdater Func имеет возвращаемую подпись Task>, но чтобы применить ее к самому базовому словарю, необходимо просто возвращаемое TValue, поэтому вы можете увидеть использование .GetAwaiter().GetResult().
Это, конечно, вызывает у меня дискомфорт, поскольку оно используется в комплексе приложение, я не хочу давать никаких шансов взаимоблокировки, так как я не смогу сразу отследить проблему.
Так что, по крайней мере, я хотел бы правильно вернуть это значение, ожидая, когда лямбда-выражение вызовет его, но это не компилируется.Вот пример его использования.

Код: Выделить всё

var pairedDevice = MasterDevices.AddOrUpdate(id,
valueCreator: () => new(this, id, true, devicePairedEventArgs.DeviceInformation.Name),
valueUpdater: async existing =>
{
// do some asynchronous stuff
await existing.VerifyUnderlyingDevice();
return existing;
});

В любом случае, мы с вторым пилотом не можем этого понять.
Помощь оценена.
Редактировать: Редактировать: Обращение к комментариям, добавление реализация, использующая семафор, чтобы предотвратить одновременную обработку данных несколькими вызовами update. Я помню, почему я сделал это таким образом: функция обновления, вызывающая процесс «проверки», представляет собой удаленный вызов ОС, и каждый отдельный запрос на обновление указывает, что изменение могло быть сделано. поэтому я не верю, что запросы на обновление одного и того же значения можно легко объединить в пул, а просто откладывать до завершения последнего.

Код: Выделить всё

public TValue AddOrUpdate(TKey key, Func valueCreator, Func valueUpdater)
{
_semaphore.WaitAsync();
try
{
return _dictionary.AddOrUpdate(key, _ => valueCreator(), (_, existingValue) => valueUpdater(existingValue).GetAwaiter().GetResult());
}
finally
{
Trace.Message($"Master count: {_dictionary.Count}");
_semaphore.Release();
}
}

Хотя я понимаю, что включение ленивости все равно поможет, шаг за шагом...
И хотя это, кажется, работает, это не решает мою проблему в любом случае используйте GetAwaiter().GetResult(). Посоветуйте пожалуйста.

Подробнее здесь: https://stackoverflow.com/questions/793 ... t-to-async