使用 Concurrent​Bag<​T> 且不允许重复

Question

我正在考虑使用 Concurrent​Bag，但我不想在我的收藏中允许重复。我的想法是，由于检查和添加到集合之间的“步骤”，这样做不会是线程安全的：

    private ConcurrentBag<IClientCallback> _callbackChannels = new ConcurrentBag<IClientCallback>();
...
    public void AddCallback(IClientCallback callback) {
        if (!_callbackChannels.Contains(callback))
        {
            _callbackChannels.Add(callback);
        }
    }

所以我在想这样的事情，但也许这是一个糟糕的想法？

        _callbackChannels = new ConcurrentBag<IClientCallback>(_callbackChannels.Union(new List<IClientCallback>() { callback }));

所以，我的问题是：这会比检查添加方法更安全吗？有什么我遗漏的，有没有更好的方法？

我们的想法是，理论上 AddCallback 可能会使用相同的回调通道对象进行多次调用 - 我知道这本身很糟糕，但我还是想处理它。

Answer 1

您可以在添加到包之前锁定。

private ConcurrentBag<IClientCallback> _callbackChannels = new ConcurrentBag<IClientCallback>();

 private object _lockObject = new Object();

    public void AddCallback(IClientCallback callback) 
    {
        lock(_lockObject)
        {
            if (!_callbackChannels.Contains(callback))
            {
                _callbackChannels.Add(callback);
            }
        }
    }

这可能会很昂贵，因为每个线程都会在较早的线程完成任务之前等待锁定。