zoukankan      html  css  js  c++  java
  • 使用Windows服务定时去执行一个方法的三种方式

    方式一:使用System.Timers.Timer定时器

    public partial class Service1 : ServiceBase
        {
           
            private UnitOfWork unitOfWork;
            private System.Timers.Timer timer1;//初始化一个定时器        
            LogHelper lghelper = new LogHelper(typeof(Service1));
            public Service1()
            {
                InitializeComponent();
                unitOfWork = new UnitOfWork();
             this.timer1 = new System.Timers.Timer();
                this.timer1.Interval = 1000;//设置定时器启动的时间间隔
                this.timer1.Elapsed += new System.Timers.ElapsedEventHandler(timer1_Elapsed);//定时器定时执行的方法          
            }
    
            protected override void OnStart(string[] args)
            {
                this.timer1.Enabled = true;//服务启动时开启定时器
                lghelper.Info("服务启动");
            }
    
            protected override void OnStop()
            {
                this.timer1.Enabled = false;//服务停止时关闭定时器
                unitOfWork.Dispose();
                lghelper.Info("服务停止");
            }
    
            private void timer1_Elapsed(object sender, System.Timers.ElapsedEventArgs e)
            {
                this.timer1.Enabled = false;//在服务运行时关闭定时器,避免在服务还没有运行结束时达到定时器时间间隔又重头开始运行(比如该定时器设置为5分钟同步一次数据,当数据量很大时,5分钟同步不完,这时达到定时器时间间隔,又会重头开始同步,所以在服务开始运行时关闭定时器)
                lghelper.Info("服务开始运行");
                try
                {
    
                    DoWork();
                }
                catch (Exception ex)
                {
                    lghelper.Error(ex.ToString());
                    lghelper.Info("服务运行失败");
                    Thread.Sleep(5000);
                }
    
                this.timer1.Enabled = true;//服务运行结束,重新启动定时器
            }
    
           
        }

    方式二:使用Task

      partial class Service2 : ServiceBase, IDisposable
        {
            LogHelper lghelper = new LogHelper(typeof(Service2));
            private CancellationTokenSource TokenSource = new CancellationTokenSource();
       protected UnitOfWork unitOfWork = new UnitOfWork();
    
            Task MainTask;
            public Service2()
            {
                InitializeComponent();
              
    
            }
            public void Dispose()
            {
                unitOfWork.Dispose();
            }
    
            protected override void OnStart(string[] args)
            {
                lghelper.Info("开启服务!");
                MainTask = Task.Factory.StartNew(() =>
                {
                    while (true)
                    {
                        try
                        {
                          DoWork();
    
                        }
                        catch (Exception ex)
                        {
                            lghelper.Error(ex.ToString());
    
                            Thread.Sleep(60 * 60 * 1000);
                        }
    
                        Thread.Sleep(5 * 60 * 1000);
                    }
    
                });
    
            }
    
            protected override void OnStop()
            {
                if (MainTask != null)
                {
                    if (MainTask.Status == TaskStatus.Running) { }
                    {
                        TokenSource.Cancel();
                        lghelper.Info("线程结束");
                    }
                }
            }
    
    
         
        }

    方式三:这个方法是看到博友的,还没有用过,不过觉得挺方便的

    http://www.cnblogs.com/ldyblogs/p/timer.html

  • 相关阅读:
    Spark源码分析之-scheduler模块
    YARN
    java.lang.NoClassDefFoundError 怎么解决
    rdd
    Apache Spark探秘:三种分布式部署方式比较
    Sqrt函数的实现方法
    golang 自旋锁的实现
    支付宝往余额宝转钱怎么保证一致性
    mysql 面试题
    TCP 进阶
  • 原文地址:https://www.cnblogs.com/stubborn-donkey/p/7656284.html
Copyright © 2011-2022 走看看