Queue/Queues.cs

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace ComLib.Queue
{
    /// <summary>
    /// This class serves as a controller for queues processors.
    /// </summary>
    public class Queues
    {
        /// <summary>
        /// Named queues.
        /// </summary>
        private static IDictionary<string, IQueueProcessor> _queues = new Dictionary<string, IQueueProcessor>();


        /// <summary>
        /// Add a new named queue processor w/ the specified name.
        /// </summary>
        /// <typeparam name="T">Type of items to put in queue.</typeparam>
        /// <param name="handler">Action to be called on item dequeue.</param>
        public static void AddProcessorFor<T>(Action<IList<T>> handler)
        {
            string namedHandler = typeof(T).FullName;
            AddProcessorFor<T>(namedHandler, handler, 10);
        }


        /// <summary>
        /// Add a new named queue processor.
        /// </summary>
        /// <typeparam name="T">Type of items to put in queue.</typeparam>
        /// <param name="itemsToDequeuePerProcess">Number of items to dequeue on dequeue operation.</param>
        /// <param name="handler">Action to be called on item dequeue.</param>
        public static void AddProcessorFor<T>(int itemsToDequeuePerProcess, Action<IList<T>> handler)
        {
            string namedHandler = typeof(T).FullName;
            AddProcessorFor<T>(namedHandler, handler, itemsToDequeuePerProcess);
        }


        /// <summary>
        /// Add a new named queue processor w/ the specified name.
        /// </summary>
        /// <typeparam name="T">Type of items to put in queue.</typeparam>
        /// <param name="namedHandler">Queue processor name.</param>
        /// <param name="handler">Action to be called on item dequeue.</param>
        public static void AddProcessorFor<T>(string namedHandler, Action<IList<T>> handler)
        {
            AddProcessorFor<T>(namedHandler, handler, 10);
        }


        /// <summary>
        /// Add a new named queue processor w/ the specified name.
        /// </summary>
        /// <typeparam name="T">Type of items to put in queue.</typeparam>
        /// <param name="namedHandler">Queue processor name.</param>