我怎样才能确保一个线程在某个任务之后得到 dibs

Question

我对多线程有点困惑。我目前正在使用 SinglaR 开发实时服务。这个想法是连接的用户可以向另一个用户请求数据。下面是请求和响应函数的概要。

考虑以下代码：

private readonly ConcurrentBag _sharedObejcts= new ConcurrentBag();

要求：

[...]

var sharedObject = new MyObject();
_sharedObejcts.Add(sharedObject);

ForwardRequestFireAndForget();

try
{
    await Task.Delay(30000, sharedObject.myCancellationToken);
}
catch
{
    return sharedObject.ResponseProperty;
}

_myConcurrentBag.TryTake(sharedObject);

[...]

回复：

[...]

var result = DoSomePossiblyVeryLengthyTaskHere();

var sharedObject = ConcurrentBag 
    .Where(x)
    .FirstOrDefault();

// The request has timed out so the object isn't there anymore.
if(sharedObject == null)
{
    return someResponse;
}

sharedObject.ResponseProperty = result;

// triggers the cancellation source
sharedObject.Cancel();

return someOtherResponse;

[...]

所以基本上是向服务器发出请求，转发到另一台主机，函数等待取消或超时。

其他主机调用响应函数，添加repsonseObject并触发myCancellationToken。

但是我不确定这是否代表竞争条件。理论上，响应线程可以检索 sharedObject 而另一个线程仍然位于 finally 块上吗？这意味着，请求已经超时，任务还没有从包中取出对象，这意味着数据不一致。

有什么保证方法可以确保在 Task.Delay() 调用之后首先调用的是 TryTake() 调用？

Answer 1

您不想让生产者取消消费者的等待。职责太多了。

相反，您真正想要的是生产者发送一个异步信号。这是通过 TaskCompletionSource<T> 完成的。消费者可以添加具有不完整 TCS 的对象，然后消费者可以（异步地）等待该 TCS 完成（或超时）。然后生产者就把它的值给TCS。

像这样：

class MyObject
{
  public TaskCompletionSource<MyProperty> ResponseProperty { get; } = new TaskCompletionSource<MyProperty>();
}


// request (consumer):

var sharedObject = new MyObject();
_sharedObejcts.Add(sharedObject);

ForwardRequestFireAndForget();

var responseTask = sharedObject.ResponseProperty.Task;
if (await Task.WhenAny(Task.Delay(30000), responseTask) != responseTask)
  return null;

_myConcurrentBag.TryTake(sharedObject);
return await responseTask;


// response (producer):

var result = DoSomePossiblyVeryLengthyTaskHere();
var sharedObject = ConcurrentBag 
    .Where(x)
    .FirstOrDefault();

// The request has timed out so the object isn't there anymore.
if(sharedObject == null)
  return someResponse;

sharedObject.ResponseProperty.TrySetResult(result);
return someOtherResponse;

上面的代码可以稍微清理一下；具体来说，让生产者拥有共享对象的“生产者视图”，让消费者拥有共享对象的“消费者视图”，这两个接口都由相同的类型实现，这并不是一个坏主意。但是上面的代码应该给了你大概的想法。

我怎样才能确保一个线程在某个任务之后得到 dibs

How can I make sure a thread gets dibs after a certain Task

c#

multithreading

thread-safety

race-condition

signalr