zoukankan      html  css  js  c++  java
  • Thread

     public partial class InterfacePolicyMainServices : ServiceBase
        {
            //服务执行间隔(s)
            /// <summary>
            /// 服务执行间隔(s)
            /// </summary>
            private const int m_updateSeconds = 180;
    
     //主工作线程
            /// <summary>
            /// 主工作线程
            /// </summary>
            private static Thread NormalRateThread;
    
     public InterfacePolicyMainServices()
            {            //设置主工作线程
                NormalRateThread = new Thread(BuildNormalRate);
    
    }
    
     protected override void OnStart(string[] args)
            {
                try
                {
                    if (!NormalRateThread.IsAlive)
                        NormalRateThread.Start();
                    m_handleLog.Handle("服务已启动", "_启动");
                }
                catch (Exception ex)
                {
                    //暂停10秒后
                    Thread.Sleep(1000 * 10);
                    OnStart(args);
                    m_handleLog.Handle(ex.GetExceptionString("政策生成服务启动发生异常:"), "_异常");
                }
            }
    
            protected override void OnStop()
            {
                try
                {
                    //暂停3秒后退出
                    Thread.Sleep(1000 * 3);
                    if (NormalRateThread.IsAlive)
                        NormalRateThread.Abort();
                    m_handleLog.Handle("服务已停止", "_停止");
                }
                catch (Exception ex)
                {
                    //暂停10秒后
                    Thread.Sleep(1000 * 10);
                    OnStop();
                    m_handleLog.Handle(ex.GetExceptionString("政策生成服务停止发生异常:"), "_异常");
                }
            }
    
        /// 生成推送政策(全、增量)
            /// </summary>
            private static void BuildNormalRate()
            {    while (true)
                {
                    try
                    {   //政策生成logic
    
         }
                    catch (Exception ex)
                    {
                        m_handleLog.Handle("政策生成服务(新)发生异常:" + ex.GetExceptionString());
                    }
                    finally
                    {
                        //GC.Collect();
                        //每隔三分钟跑一次
                        Thread.Sleep(m_updateSeconds * 1000);
                    }
    
          }
         }
    
  • 相关阅读:
    C语言I博客作业11
    第十四周助教总结
    C语言I博客作业10
    Tensorflow--MNIST简单全连接层分类
    记一些好看的Android开源菜单
    AS更新到3.5.2遇到ERROR: SSL peer shut down incorrectly问题
    Tensorflow tf.app.flags 的使用
    Android Sensor(传感器)
    《第一行代码》百分比布局出现的问题
    当Turtle遇见柯南?
  • 原文地址:https://www.cnblogs.com/niejun/p/3884238.html
Copyright © 2011-2022 走看看