程式師世界 >> 編程語言 >> .NET網頁編程 >> ASP.NET >> ASP.NET基礎 >> asp.net 計劃任務管理程序實現，多線程任務加載

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

編輯：ASP.NET基礎

asp.net下實現可以將計劃任務的方法放在global裡，使用一個統一的任務管理類來管理各種任務的執行，做到並行不悖！
下面是我寫的一個方法，希望起個拋磚引玉的作用！大家一起學習下：

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

復制代碼代碼如下:
/// <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 + "
第三步，定義要做的動作處理類，繼承第一步定義的接口，下面的例子是一個定時郵件發送程序，在規定的時間段執行郵件發送：
復制代碼代碼如下:
/// <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"></script>

如果使用ajax連接此管理類模擬客戶端timer事件經行處理也是可以的！當然方法不是唯一的，此程序可能存在一些不足之處，歡迎大家指正！