2

C＃には遅延キューの標準的な実装がないため、C＃で遅延キューを実装する必要があります。System.Threading.Timerノードの遅延エンキューを実装するため に使用したいと考えています。

public class DelayQueue<T>
{
    private Queue queue<T> = new Queue<T>();

    public void Enqueue(Object object)
    {
        this.queue.Enqueue(object as T);
    }

    public void Enqueue(T node, TimeSpan dueTime)
    {
         new System.Threading.Timer(this.Enqueue, node, dueTime, -1);
    }

    .
    .
    .
}

このアプローチは私には問題ないように見えますが、私はC＃（Cのバックグラウンドから）に慣れていないので、それが正しい方法であるか、それとも同じことを行うためのより良い、より効果的な方法があるかどうかについて誰かに意見を求めます。

4

1 に答える 1

4

アイテムごとにタイマーを作成するのは良い考えではないと思います。とにかく、キューからアイテムをデキューするときに最初の準備ができたアイテムを取得する必要があるだけで、アイテムが準備ができる時間を保存できます。

public class DelayQueue<T>
{
    private List<DelayQueueItem<T>> items = new List<DelayQueueItem<T>>();

    public void Enqueue(T item)
    {
        Enqueue(item, TimeSpan.Zero);
    }

    public void Enqueue(T item, TimeSpan delay)
    {
        items.Add(new DelayQueueItem<T>()
        {
            Value = item,
            ReadyTime = DateTime.Now.Add(delay)
        });
    }

    public T Dequeue()
    {
        DateTime now = DateTime.Now;
        var item = items.FirstOrDefault(i => i.ReadyTime <= now);
        if (item != null)
        {
            items.Remove(item);
            return item.Value;
        }

        return default(T);
    }

    private class DelayQueueItem<T>
    {
        public T Value { get; set; }
        public DateTime ReadyTime { get; set; }
    }
}

UPDATE（待機タイムアウトでキューをブロックする）

public T Dequeue()
{
    return Dequeue(TimeSpan.Zero);
}

public T Dequeue(TimeSpan timeout)
{
    DateTime startTime = DateTime.Now;

    do
    {
        DateTime now = DateTime.Now;

        var item = items.FirstOrDefault(i => i.ReadyTime <= now);
        if (item == null)
            continue;

        items.Remove(item);
        return item.Value;
    }
    while (DateTime.Now - startTime < timeout);

    return default(T);
}

使用法：

DelayQueue<string> queue = new DelayQueue<string>();
queue.Enqueue("world", new TimeSpan(0, 0, 1));
queue.Enqueue("hello");                        
queue.Enqueue(",");

TimeSpan timeout = new TimeSpan(0, 0, 2);
Console.WriteLine(queue.Dequeue());
Console.WriteLine(queue.Dequeue(timeout));
Console.WriteLine(queue.Dequeue(timeout));
于 2013-01-26T14:54:26.357 に答える