CJCMS系列---說說項目中的任務管理模式

　　在系統開發過程中，肯定會有許多比較大型的任務需要去做，例如給所有注冊的用戶發送推廣郵件，可是要是注冊用戶達到幾十萬級別，那我想這個發送郵件的工作可能真的讓你很頭疼，幾十萬的發送量，根本無法保證發送過程不會出錯，被應用程序池回收，畢竟占得內存太大了，或者耗時過長。那任務管理不得不提上來講講了。

　　任務管理，最重要的就是保證任務能夠完整的完成，不管遇到什么問題，是否線程崩潰或被回收。

　　就拿你要發郵件做例子，這么多的郵件，我想不可能一次就發完的，那我們就隔幾分鍾發送1000人也好啊。

　　下面是代碼：

　　

/******************************************************************
* 作者:                    不要理我 CJ
* 郵件：               [e-mail](僅僅支持商業合作洽談)
* 創建時間:                2012-8-16 20:12:38
* 最后修改時間:            2012-8-16 20:12:38
* 
* 未經修改的文件版權屬於原作者所有，但是你可以閱讀，修改，調試。本項目不建議商用，不能確保穩定性。
* 同時由於項目bug引起的一切問題，原作者概不負責。
*
* 本項目所引用的所有類庫，仍然遵循其原本的協議，不得侵害其版權。
*
* 您一旦下載就視為您已經閱讀此聲明。
*
* 您不可以移除項目中的任何聲明。
*******************************************************************/
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace CJCMS.Framework.Task
{
    public interface IBackgroundTask
    {
        bool IsWorking { get; set; }
        void DoWork();
    }
}

 

/******************************************************************
* 作者:                    不要理我 CJ
* 郵件：               [e-mail](僅僅支持商業合作洽談)
* 創建時間:                2012-8-16 21:17:01
* 最后修改時間:            2012-8-16 21:17:01
* 
* 未經修改的文件版權屬於原作者所有，但是你可以閱讀，修改，調試。本項目不建議商用，不能確保穩定性。
* 同時由於項目bug引起的一切問題，原作者概不負責。
*
* 本項目所引用的所有類庫，仍然遵循其原本的協議，不得侵害其版權。
*
* 您一旦下載就視為您已經閱讀此聲明。
*
* 您不可以移除項目中的任何聲明。
*******************************************************************/

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

namespace CJCMS.Framework.Task
{
    public class DefaultBackgroundTask:IBackgroundTask
    {
        public bool IsWorking { get; set; }

        public DefaultBackgroundTask()
        {
            IsWorking = true;
        }

        public int k = 0;
        public void DoWork()
        {
            k += 1;//當然這里實現發郵件也是可以的。
        }
    }
}

/******************************************************************
* 作者:                    不要理我 CJ
* 郵件：               [e-mail](僅僅支持商業合作洽談)
* 創建時間:                2012-8-16 20:14:04
* 最后修改時間:            2012-8-16 20:14:04
* 
* 未經修改的文件版權屬於原作者所有，但是你可以閱讀，修改，調試。本項目不建議商用，不能確保穩定性。
* 同時由於項目bug引起的一切問題，原作者概不負責。
*
* 本項目所引用的所有類庫，仍然遵循其原本的協議，不得侵害其版權。
*
* 您一旦下載就視為您已經閱讀此聲明。
*
* 您不可以移除項目中的任何聲明。
*******************************************************************/
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Timers;

namespace CJCMS.Framework.Task
{
    public interface IBackgroundTaskManager
    {
        Timer _timer { get; set; }
        void Elapsed(object sender, ElapsedEventArgs e);
    }
}

/******************************************************************
* 作者:                    不要理我 CJ
* 郵件：               [e-mail](僅僅支持商業合作洽談)
* 創建時間:                2012-8-16 20:52:35
* 最后修改時間:            2012-8-16 20:52:35
* 
* 未經修改的文件版權屬於原作者所有，但是你可以閱讀，修改，調試。本項目不建議商用，不能確保穩定性。
* 同時由於項目bug引起的一切問題，原作者概不負責。
*
* 本項目所引用的所有類庫，仍然遵循其原本的協議，不得侵害其版權。
*
* 您一旦下載就視為您已經閱讀此聲明。
*
* 您不可以移除項目中的任何聲明。
*******************************************************************/

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

namespace CJCMS.Framework.Task
{
    public class DefaultBackgroundTaskManager:IBackgroundTaskManager
    {
        public Timer _timer { get; set; }
        private static Dictionary<string, IBackgroundTask> _entries = new Dictionary<string, IBackgroundTask>();

        public TimeSpan Interval
        {
            get { return TimeSpan.FromMilliseconds(_timer.Interval); }
            set { _timer.Interval = value.TotalMilliseconds; }
        }

        public DefaultBackgroundTaskManager(double min)
        {
            _timer = new Timer();
            Interval = TimeSpan.FromMinutes(min);
            _timer.Elapsed += Elapsed;
            _timer.Start();
        }

        public void Elapsed(object sender, ElapsedEventArgs e)
        {
            if (!System.Threading.Monitor.TryEnter(_timer))
                return;

            try
            {
                if (_timer.Enabled)
                {
                    foreach (KeyValuePair<string, IBackgroundTask> k in _entries.ToList())
                    {
                        if (k.Value.IsWorking)
                        {
                            k.Value.DoWork();
                        }
                        else
                        {
                            Remove(k.Key);
                        }
                    }
                }
            }
            catch (Exception ex)
            {
               
            }
            finally
            {
                System.Threading.Monitor.Exit(_timer);
            }
            
        }

        ~DefaultBackgroundTaskManager()
        {
            _timer.Stop();
        }

        private static void Add(string key, IBackgroundTask task)
        {
            lock (_entries)
            {
                _entries.Add(key, task);
            }
        }

        public static void Remove(string key)
        {
            lock (_entries)
            {
                _entries.Remove(key);
            }
        }

        public static void TryAdd(string key, IBackgroundTask task)
        {
            if (_entries.Where(a => a.Key == key).Count() == 0)
            {
                Add(key, task);
            }
        }
    }
}

　　你看到了，任務管理其實是用了Timer來實現，我設計一個定時器，隔幾分鍾就執行以下任務，不管成功不成功，都得執行。

　　但是你得注意，這個執行是重新執行的意思，所以假若你想實現發送郵件，放置一直重復發送，你可以用一張表記錄發送到哪里了，放置一直在發送。任務沒有實現記錄任務狀態，后面也許我會改進改進，讓這個任務管理記住狀態，但是我覺得很難抽象出所有的任務類型。