asp.net 計劃任務管理程序實現，多線程任務加載

第一步定義一個接口，用來規范任務必須要實現的動作，該接口只有一個方法（簡單起見）：

代碼如下:

/// <summary> 
/// 工作單元接口,定義一個計劃任務必須完成的工作 
/// </summary> 
public interface IScheduledTask 
{ 
/// <summary> 
/// 任務執行 
/// </summary> 
void Execute(); 
} 
 
第二步，定義一個類，用來管理計劃任務的執行和關閉： 
 代碼如下:

/// <summary> 
/// 用來執行計劃任務的基本對象 
/// </summary> 
public class ScheduledTask 
{ 
private static readonly ScheduledTask _ScheduledTask = null; 
private Timer UpdateTimer = null; 
/// <summary> 
/// 間隔時間,單位為毫秒 
/// </summary> 
private int interval = 10 * 1000; 
/// <summary> 
/// 間隔時間,單位為毫秒 
/// </summary> 
public int Interval 
{ 
get { return this.interval; } 
set { this.interval = value; } 
} 
/// <summary> 
/// 任務是否完成標志 
/// </summary> 
private int _IsRunning; 
/// <summary> 
/// 靜態構造函數,保證實例的唯一性 
/// </summary> 
static ScheduledTask() 
{ 
_ScheduledTask = new ScheduledTask(); 
} 
/// <summary> 
/// 任務隊列 
/// </summary> 
private ArrayList tasks = new ArrayList(); 
/// <summary> 
/// 任務隊列 
/// </summary> 
public ArrayList Tasks { get { return tasks; } } 
/// <summary> 
/// 返回任務實例 
/// </summary> 
/// <returns></returns> 
public static ScheduledTask Instance() 
{ 
return _ScheduledTask; 
} 
/// <summary> 
/// 執行任務 
/// </summary> 
public void Start() 
{ 
if (UpdateTimer == null) 
{ 
UpdateTimer = new Timer(new TimerCallback(UpdateTimerCallback), null, interval, interval); 
} 
} 
/// <summary> 
/// 任務處理 
/// </summary> 
/// <param name="sender"></param> 
private void UpdateTimerCallback(object sender) 
{ 
if (Interlocked.Exchange(ref _IsRunning, 1) == 0) 
{ 
try 
{ 
//執行多個任務 
foreach (IScheduledTask task in Tasks) 
{ 
ThreadStart myThreadDelegate = new ThreadStart(task.Execute); 
Thread myThread = new Thread(myThreadDelegate); 
myThread.Start(); 
} 
} 
catch (Exception ex) 
{ 
//錯誤處理 
CreateLog(ex.Message, true); 
} 
finally 
{ 
Interlocked.Exchange(ref _IsRunning, 0); 
} 
} 
} 
/// <summary> 
/// 取消任務 
/// </summary> 
public void Stop() 
{ 
if (UpdateTimer != null) 
{ 
UpdateTimer.Dispose(); 
UpdateTimer = null; 
} 
} 
/// <summary> 
/// 記錄日志至文本文件 
/// </summary> 
/// <param name="message"></param> 
/// <param name="iserror"></param> 
public static void CreateLog(string message, bool iserror) 
{ 
DateTime dt = DateTime.Now; 
int y = dt.Year;//當前的年份 
int m = dt.Month;//當前的月份 
string root = HttpRuntime.AppDomainAppPath; 
root += "ScheduledTaskLogs"; 
if (!File.Exists(root)) Directory.CreateDirectory(root); 
string dir_y = root + "\\" + y.ToString(); 
string dir_m = dir_y + "\\" + m.ToString(); 
string err = iserror ? "_taskerror" : "_task"; 
string dirOk = dir_m + "\\" + dt.Year + dt.Month + dt.Day + err + ".txt"; 
//以當前年份為名創建新目錄 
if (!File.Exists(dir_y)) Directory.CreateDirectory(dir_y); 
//以當前月份為名創建新目錄 
if (!File.Exists(dir_m)) Directory.CreateDirectory(dir_m); 
string err1 = iserror ? "錯誤" : ""; 
if (File.Exists(dirOk)) 
{ 
StreamWriter sr = new StreamWriter(dirOk, true, Encoding.Default); 
lock (sr) 
{ 
sr.WriteLine(); 
sr.WriteLine("--------------計劃任務" + err1 + "日志-----------------------------------------------------------------------"); 
sr.WriteLine(err1 + "時間: " + DateTime.Now.ToString()); 
sr.WriteLine("詳細內容: " + message); 
sr.WriteLine("--------------------------------------------------------------------------------------------"); 
} 
sr.Close(); 
sr.Dispose(); 
} 
else 
{ 
StreamWriter sr = new StreamWriter(dirOk, false, Encoding.Default); 
lock (sr) 
{ 
sr.WriteLine(); 
sr.WriteLine("--------------計劃任務" + err1 + "日志-----------------------------------------------------------------------"); 
sr.WriteLine(err1 + "時間: " + DateTime.Now.ToString()); 
sr.WriteLine("詳細內容: " + message); 
sr.WriteLine("--------------------------------------------------------------------------------------------"); 
} 
sr.Close(); 
sr.Dispose(); 
} 
} 
} 
 
第三步，定義要做的動作處理類，繼承第一步定義的接口，下面的例子是一個定時郵件發送程序，在規定的時間段執行郵件發送： 
 代碼如下:

/// <summary> 
/// 計劃任務--定時發送郵件 
/// </summary> 
public class Task_MailSend : IScheduledTask 
{ 
public void Execute() 
{ 
string nw = DateTime.Now.ToString("HH"); 
int hh = 0; 
if (!Int32.TryParse(nw, out hh)) { return; } 
//每天11-13點發送郵件 
if (hh < 10 || hh > 17) 
{ 
ScheduledTask.CreateLog("沒到發送時間", true); 
return; 
} 
DataTable dt = GetOrderedUser(); 
int num = dt.Rows.Count; 
if (num == 0) 
{ 
ScheduledTask.CreateLog("目前沒有用戶訂閱", true); 
return; 
} 
/* 
mail發送程序。。 
*/ 
} 
 
好了，執行上面三步后，剩下的工作就交給global來做了！ 
 代碼如下:

<script runat="server"><!-- 
void Application_Start(object sender, EventArgs e) 
{ 
// 在應用程序啟動時運行的代碼 
//WildRen.Common是我這里的命名空間 
WildRen.Common.ScheduledTask.Instance().Interval = 12 * 60 * 60000;//設置計劃任務執行時間間隔 
WildRen.Common.ScheduledTask.Instance().Tasks.Add(new Task_MailSend());//向計劃任務管理程序添加要執行的動作 
WildRen.Common.ScheduledTask.Instance().Start();//啟動任務 
} 
void Application_End(object sender, EventArgs e) 
{ 
// 在應用程序關閉時運行的代碼 
WildRen.Common.ScheduledTask.Instance().Stop(); 
} 
// --></script> 
 
如果使用ajax連接此管理類模擬客戶端timer事件經行處理也是可以的！當然方法不是唯一的，此程序可能存在一些不足之處，歡迎大家指正！
 
 




聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。TEL:177 7030 7066 E-MAIL:11247931@qq.com