在Global中使用线程隔时执行一项任务
2008-09-18 08:52
267 查看
GLOBAL中线程的应用(书中学习,整理了一下),以下是过5分钟删除一张表的记录
using System;
using System.Collections;
using System.ComponentModel;
using System.Web;
using System.Web.SessionState;
using DataBase;
using System.Data.SqlClient;
using System.Web.Security;
using System.IO ;
using System.Threading;
namespace FreightCom
{
/// <summary>
/// Global 的摘要说明。
/// </summary>
public class Global : System.Web.HttpApplication
{
/// <summary>
/// 必需的设计器变量。
/// </summary>
private System.ComponentModel.IContainer components = null;
private OnLineUser ou=new OnLineUser();
private UserLoginInfo Login=new UserLoginInfo();
public Global()
{
InitializeComponent();
}
protected void Application_Start(Object sender, EventArgs e)
{
SchedulerAgent.StartAgent();
}
protected void Session_Start(Object sender, EventArgs e)
{
}
protected void Application_BeginRequest(Object sender, EventArgs e)
{
}
protected void Application_EndRequest(Object sender, EventArgs e)
{
}
protected void Application_AuthenticateRequest(Object sender, EventArgs e)
{
}
protected void Application_Error(Object sender, EventArgs e)
{
}
protected void Session_End(Object sender, EventArgs e)
{
}
protected void Application_End(Object sender, EventArgs e)
{
SchedulerAgent.Stop();
}
#region Web 窗体设计器生成的代码
/// <summary>
/// 设计器支持所需的方法 - 不要使用代码编辑器修改
/// 此方法的内容。
/// </summary>
private void InitializeComponent()
{
this.components = new System.ComponentModel.Container();
}
#endregion
}
public interface ISchedulerJob
{
void Execute();
}
public class SchedulerConfiguration
{
private int sleepInterval;
private ArrayList jobs=new ArrayList();
public int SleepInterval
{
get{return sleepInterval;}
}
public ArrayList Jobs
{
get {return jobs;}
}
public SchedulerConfiguration(int newSleepInterval)
{
sleepInterval=newSleepInterval;
}
}
public class Scheduler
{
private SchedulerConfiguration configuration = null;
public Scheduler(SchedulerConfiguration config)
{
configuration=config;
}
public void Start()
{
while(true)
{
try
{
foreach(ISchedulerJob job in configuration .Jobs)
{
job.Execute();
}
}
catch{}
finally
{
Thread.Sleep(configuration.SleepInterval);
}
}
}
}
public class SchedulerAgent
{
private static System.Threading.Thread schedulerThread=null;
public static void StartAgent()
{
SchedulerConfiguration config=new SchedulerConfiguration(1000*300);//设置时间,此处为5分钟
config.Jobs.Add(new AlertJob());
Scheduler scheduler=new Scheduler(config);
System.Threading.ThreadStart myThreadStart=new System.Threading.ThreadStart(scheduler.Start);
schedulerThread=new System.Threading.Thread(myThreadStart);
schedulerThread.Start();
}
public static void Stop()
{
if(null!=schedulerThread)
{
schedulerThread.Abort();
}
}
}
public class AlertJob:ISchedulerJob
{
private OnLineUser ou=new OnLineUser();
public void Execute()
{
ou.UserDelOnline();//一个删除的方法
}
}
}
using System;
using System.Collections;
using System.ComponentModel;
using System.Web;
using System.Web.SessionState;
using DataBase;
using System.Data.SqlClient;
using System.Web.Security;
using System.IO ;
using System.Threading;
namespace FreightCom
{
/// <summary>
/// Global 的摘要说明。
/// </summary>
public class Global : System.Web.HttpApplication
{
/// <summary>
/// 必需的设计器变量。
/// </summary>
private System.ComponentModel.IContainer components = null;
private OnLineUser ou=new OnLineUser();
private UserLoginInfo Login=new UserLoginInfo();
public Global()
{
InitializeComponent();
}
protected void Application_Start(Object sender, EventArgs e)
{
SchedulerAgent.StartAgent();
}
protected void Session_Start(Object sender, EventArgs e)
{
}
protected void Application_BeginRequest(Object sender, EventArgs e)
{
}
protected void Application_EndRequest(Object sender, EventArgs e)
{
}
protected void Application_AuthenticateRequest(Object sender, EventArgs e)
{
}
protected void Application_Error(Object sender, EventArgs e)
{
}
protected void Session_End(Object sender, EventArgs e)
{
}
protected void Application_End(Object sender, EventArgs e)
{
SchedulerAgent.Stop();
}
#region Web 窗体设计器生成的代码
/// <summary>
/// 设计器支持所需的方法 - 不要使用代码编辑器修改
/// 此方法的内容。
/// </summary>
private void InitializeComponent()
{
this.components = new System.ComponentModel.Container();
}
#endregion
}
public interface ISchedulerJob
{
void Execute();
}
public class SchedulerConfiguration
{
private int sleepInterval;
private ArrayList jobs=new ArrayList();
public int SleepInterval
{
get{return sleepInterval;}
}
public ArrayList Jobs
{
get {return jobs;}
}
public SchedulerConfiguration(int newSleepInterval)
{
sleepInterval=newSleepInterval;
}
}
public class Scheduler
{
private SchedulerConfiguration configuration = null;
public Scheduler(SchedulerConfiguration config)
{
configuration=config;
}
public void Start()
{
while(true)
{
try
{
foreach(ISchedulerJob job in configuration .Jobs)
{
job.Execute();
}
}
catch{}
finally
{
Thread.Sleep(configuration.SleepInterval);
}
}
}
}
public class SchedulerAgent
{
private static System.Threading.Thread schedulerThread=null;
public static void StartAgent()
{
SchedulerConfiguration config=new SchedulerConfiguration(1000*300);//设置时间,此处为5分钟
config.Jobs.Add(new AlertJob());
Scheduler scheduler=new Scheduler(config);
System.Threading.ThreadStart myThreadStart=new System.Threading.ThreadStart(scheduler.Start);
schedulerThread=new System.Threading.Thread(myThreadStart);
schedulerThread.Start();
}
public static void Stop()
{
if(null!=schedulerThread)
{
schedulerThread.Abort();
}
}
}
public class AlertJob:ISchedulerJob
{
private OnLineUser ou=new OnLineUser();
public void Execute()
{
ou.UserDelOnline();//一个删除的方法
}
}
}
相关文章推荐
- Global中使用线程隔时执行一项任务(ZT)
- Global中使用线程隔时执行一项任务
- Global中使用线程隔时执行一项任务
- GCD的简单使用,开辟一条新的线程,让上面的任务串行执行
- 在Global中使用线程隔时处理任务
- 使用 Task 替换 ThreadPool ,异步监测所有线程(任务)是否全部执行完毕
- Thread线程使用等待唤醒机制实现线程交替执行任务
- 多线程异步编程(1):创建多个线程执行任务,同时更新进度条,使用WaitHandle发送信号
- Java中使用ThreadPoolExecutor并行执行独立的单线程任务
- Service学习——第五篇 使用IntentService在单独线程上执行异步任务
- Android中使用Handler和异步任务(AsyncTack)来为UI线程执行费时操作
- C# 使用 Task 替换 ThreadPool ,异步监测所有线程(任务)是否全部执行完毕
- 多线程异步编程(2):创建多个线程执行任务,同时更新进度条,使用观察者模式,利用事件通知界面更新。移除对Form的引用,彻底解除界面与逻辑的耦合
- Android中使用Handler和异步任务(AsyncTack)来为UI线程执行费时操作
- [并发并行]_[任务停止]_[使用Pthread的线程本地存储来停止任务执行]
- 使用ThreadPoolExecutor并行执行独立的单线程任务
- Java中使用ThreadPoolExecutor并行执行独立的单线程任务
- 项目中使用到的封装---后台子线程执行任务,前台显示加载条
- 使用ThreadPoolExecutor并行执行独立的单线程任务
- 使用Spring定时任务并且通过AOP监控任务执行情况