GetOrCreateQueue()

static Queue System.Net.TimerThread.GetOrCreateQueue ( int durationMilliseconds )

inlinestaticpackage

Definition at line 339 of file TimerThread.cs.

    {
        if (durationMilliseconds == -1)
        {
            return new InfiniteTimerQueue();
        }
        if (durationMilliseconds < 0)
        {
            throw new ArgumentOutOfRangeException("durationMilliseconds");
        }
        object key = durationMilliseconds;
        WeakReference weakReference = (WeakReference)s_queuesCache[key];
        TimerQueue timerQueue;
        if (weakReference == null || (timerQueue = (TimerQueue)weakReference.Target) == null)
        {
            lock (s_newQueues)
            {
                weakReference = (WeakReference)s_queuesCache[key];
                if (weakReference == null || (timerQueue = (TimerQueue)weakReference.Target) == null)
                {
                    timerQueue = new TimerQueue(durationMilliseconds);
                    weakReference = new WeakReference(timerQueue);
                    s_newQueues.AddLast(weakReference);
                    s_queuesCache[key] = weakReference;
                    if (++s_cacheScanIteration % 32 == 0)
                    {
                        List<object> list = new List<object>();
                        IDictionaryEnumerator enumerator = s_queuesCache.GetEnumerator();
                        while (enumerator.MoveNext())
                        {
                            DictionaryEntry entry = enumerator.Entry;
                            if (((WeakReference)entry.Value).Target == null)
                            {
                                list.Add(entry.Key);
                            }
                        }
                        for (int i = 0; i < list.Count; i++)
                        {
                            s_queuesCache.Remove(list[i]);
                        }
                    }
                }
            }
        }
        return timerQueue;
    }

References System.key, System.list, System.Net.TimerThread.s_cacheScanIteration, System.Net.TimerThread.s_newQueues, and System.Net.TimerThread.s_queuesCache.