ब्लॉकिंग कोलेक्शन में ConcurrentDictionary को कैसे लपेटें?

Question

मैं इसे ब्लॉकिंग कोलेक्शन में लपेटकर एक ConcurrentDictionary को कार्यान्वित करने का प्रयास करता हूं लेकिन सफल नहीं हुआ।

मैं समझता हूँ कि एक चर घोषणाओं, आदि BlockingCollection जैसे ConcurrentBag<T>, ConcurrentQueue<T> के साथ काम

तो, एक ConcurrentBag एक BlockingCollection में लिपटे बनाने के लिए मैं घोषणा करेंगे और इस तरह का दृष्टांत:

BlockingCollection<int> bag = new BlockingCollection<int>(new ConcurrentBag<int>()); 

लेकिन ConcurrentDictionary के लिए यह कैसे करें? मुझे निर्माता और उपभोक्ता पक्ष दोनों पर ब्लॉकिंग कोलेक्शन की अवरुद्ध कार्यक्षमता की आवश्यकता है।

Answer 1

आप अपनी खुद की एडाप्टर वर्ग लिखने के लिए की आवश्यकता होगी - तरह कुछ:

public class ConcurrentDictionaryWrapper<TKey,TValue> : IProducerConsumerCollection<KeyValuePair<TKey,TValue>> 
{ 
    private ConcurrentDictionary<TKey, TValue> dictionary; 

    public IEnumerator<KeyValuePair<TKey, TValue>> GetEnumerator() 
    { 
     return dictionary.GetEnumerator(); 
    } 

    IEnumerator IEnumerable.GetEnumerator() 
    { 
     return GetEnumerator(); 
    } 

    public void CopyTo(Array array, int index) 
    { 
     throw new NotImplementedException(); 
    } 

    public int Count 
    { 
     get { return dictionary.Count; } 
    } 

    public object SyncRoot 
    { 
     get { return this; } 
    } 

    public bool IsSynchronized 
    { 
     get { return true; } 
    } 

    public void CopyTo(KeyValuePair<TKey, TValue>[] array, int index) 
    { 
     throw new NotImplementedException(); 
    } 

    public bool TryAdd(KeyValuePair<TKey, TValue> item) 
    { 
     return dictionary.TryAdd(item.Key, item.Value); 
    } 

    public bool TryTake(out KeyValuePair<TKey, TValue> item) 
    { 
     item = dictionary.FirstOrDefault(); 
     TValue value; 
     return dictionary.TryRemove(item.Key, out value); 
    } 

    public KeyValuePair<TKey, TValue>[] ToArray() 
    { 
     throw new NotImplementedException(); 
    } 
} 

Answer 2

शायद तुम blockingCollection

 ConcurrentDictionary<int, BlockingCollection<string>> mailBoxes = new ConcurrentDictionary<int, BlockingCollection<string>>(); 
     int maxBoxes = 5; 

     CancellationTokenSource cancelationTokenSource = new CancellationTokenSource(); 
     CancellationToken cancelationToken = cancelationTokenSource.Token; 

     Random rnd = new Random(); 
     // Producer 
     Task.Factory.StartNew(() => 
     { 
      while (true) 
      { 
       int index = rnd.Next(0, maxBoxes); 
       // put the letter in the mailbox 'index' 
       var box = mailBoxes.GetOrAdd(index, new BlockingCollection<string>()); 
       box.Add("some message " + index, cancelationToken); 
       Console.WriteLine("Produced a letter to put in box " + index); 

       // Wait simulating a heavy production item. 
       Thread.Sleep(1000); 
      } 
     }); 

     // Consumer 1 
     Task.Factory.StartNew(() => 
     { 
      while (true) 
      { 
       int index = rnd.Next(0, maxBoxes); 
       // get the letter in the mailbox 'index' 
       var box = mailBoxes.GetOrAdd(index, new BlockingCollection<string>()); 
       var message = box.Take(cancelationToken); 
       Console.WriteLine("Consumed 1: " + message); 

       // consume a item cost less than produce it: 
       Thread.Sleep(50); 
      } 
     }); 

     // Consumer 2 
     Task.Factory.StartNew(() => 
     { 
      while (true) 
      { 
       int index = rnd.Next(0, maxBoxes); 
       // get the letter in the mailbox 'index' 
       var box = mailBoxes.GetOrAdd(index, new BlockingCollection<string>()); 
       var message = box.Take(cancelationToken); 
       Console.WriteLine("Consumed 2: " + message); 

       // consume a item cost less than produce it: 
       Thread.Sleep(50); 
      } 
     }); 

     Console.ReadLine(); 
     cancelationTokenSource.Cancel(); 

की समवर्ती शब्दकोश की जरूरत है इस तरह से, एक उपभोक्ता जो कुछ उम्मीद कर रही है तक मेलबॉक्स 5 में, जब तक उत्पादक मेलबॉक्स 5 में कोई पत्र नहीं डालता तब तक इंतजार करेगा।