Windows服务和计时器

Question

我正在学习创建Windows服务和线程。我正在使用由同事提供的图书馆，它帮助建立线程服务，但这并没有给我基本的知识。假设我将有一个长期运行的服务（比网上提供的基本示例稍微提前一些），需要每15秒唤醒一次，然后执行其操作（基本上将始终运行）。行动包括在数据库中查找状态，然后执行操作。

应该如何以下在这样的情况下进行处理：
1.设置所述螺纹
2.情况下动作时间比间隔执行。

我发现了下面的例子，但我有上述2点的问题。请记住，该服务将始终运行。

http://www.java2s.com/Tutorial/CSharp/0280__Development/CreatethedelegatethattheTimerwillcall.htm

using System; 
using System.Threading; 

class MainClass 
{ 
    public static void CheckTime(Object state) 
    { 
    Console.WriteLine(DateTime.Now); 
    } 

    public static void Main() 
    { 
    TimerCallback tc = new TimerCallback(CheckTime); 


    Timer t = new Timer(tc, null, 1000, 500); 

    Console.WriteLine("Press Enter to exit"); 
    int i = Console.Read(); 

    // clean up the resources 
    t.Dispose(); 
    t = null; 
    } 
} 

所以在我的例子，你会在
1.停止事件
2.去是否启动事件看起来不错？
3.如果在队列中没有发现什么应该发生？
4.如果动作花费的时间比间隔更长，会怎么样？

public partial class QueueService : ServiceBase 
    { 


     public QueueService() 
     { 
      InitializeComponent(); 
     } 

     protected override void OnStart(string[] args) 
     { 
      try 
      { 
       TimerCallback tc = new TimerCallback(CheckQueue); 


      Timer t = new Timer(tc, null, 10000, 15000); //first time wait for 10seconds and then execte every 15seconds 

      } 
      catch (Exception ex) 
      { 
     what should i be checking here and then also make sure that the threading/timer doesn't stop. It should still execute every 15 seconds 
      } 
     } 

     protected override void OnStop() 
     { 

     what needs to go here... 

     } 

     private static void CheckQueue(Object state) 
    { 
      ... Connect to the DB 
     ... Check status 
     ... if queue status found then perform actions 
     . A 
     . C 
     . T 
     . I 
     . O 
     . N 
     . S 
     ... if end 

    } 

    } 

感谢您的期待！

Answer 1

1. 处置定时器。
2. 不完全。您需要在课堂级别声明计时器，否则将在少量迭代后收集计时器。
3. 没有。

4. 在检查队列并在完成之后再次启动它之前停止计时器。这样你就不会陷入共享内存或其他冲突的麻烦中。

   公共部分类QueueService：ServiceBase {

   定时器定时器;

   public QueueService() 
   { 
       InitializeComponent(); 
   } 
   
   protected override void OnStart(string[] args) 
   { 
       try 
       { 
        TimerCallback tc = new TimerCallback(CheckQueue); 
   
        timer = new Timer(tc, null, 10000, 15000); 
       } 
       catch (Exception ex) 
       { 
   
       } 
   } 
   
   protected override void OnStop() 
   { 
       if (timer != null) 
        timer.Dispose(); 
   } 
   
   private static void CheckQueue(Object state) 
   { 
       timer.Change(Timeout.Infinite, 0); 
   
       ... Connect to the DB 
       ... Check status 
       ... if queue status found then perform actions 
       . A 
       . C 
       . T 
       . I 
       . O 
       . N 
       . S 
       ... if end 
   
       timer.Change(10000, 15000); 
   
   } 
   

   }