using System.Collections;
using System.Collections.Concurrent;
using System.Collections.Generic;
using Christie_net.datagear.command;

namespace Christie_net.datagear {
public class WaitList {
    private Dictionary<string, BlockingCollection<Command>> waitlist = new Dictionary<string, BlockingCollection<Command>>();
    private object syncObject = new object();

    public void add(Command cm) {
        lock (syncObject) {
            if (waitlist.ContainsKey(cm.key)) {
                waitlist[cm.key].TryAdd(cm);
            } else {
                BlockingCollection<Command> queue = new BlockingCollection<Command>();
                queue.TryAdd(cm);
                waitlist.Add(cm.key, queue);
            }
        }
    }


    public bool ContainsKey(string key) {
        lock (syncObject) {
            return waitlist.ContainsKey(key);   
        }
    }
}
}