线程池被Windows服务使用问题

Question

我创建了一个 Windows 服务，当前有三个计时器。第一个计时器每 15 秒唤醒一次，第二个计时器每分钟唤醒一次。第三个计时器每天都会醒来。

问题是这些线程每次都会生成新线程，并且有一次线程池完全用完。是否有任何方法只生成 3 个线程而不生成更多新线程。

我的代码看起来像这样：

protected Onstart()
{
  var timer1  = new TImer();
  timer.Elapsed += Event1;
  timer1.interval = 60000;
  timer1.start();

  var timer2  = new TImer();
  timer2.Elapsed += Event2;
  timer2.interval = 60000;
  timer2.start();
}

private Event1(object,elapsedeventargs)
{
  var workerthread1 = **new thread**(workerthreadfunc1)
  workerthread1.start();
}

private Event2(object,elapsedeventargs)
{
  var workerthread2 = **new thread**(workerthreadfunc2)
  workerthread2.start();
}

正如你所看到的，它正在创建新线程，它将在某个时刻用完线程池中的所有线程并突然停止 Windows 服务。目前它正在停止并记录事件 ID 为 5000 的 evet 日志。

Answer 1

您的问题不在于线程池。每次计时器之一“滴答”时，您都会创建自己的线程。我不知道workerthreadfunc1和workerthreadfunc2在做什么，但如果它们没有返回，那么您将继续创建越来越多的线程。

如果您使用 System.Timers.Timer，则 Elapsed 事件已经在 ThreadPool 线程上。为什么不在那里执行您想要的操作呢？

Answer 2

不要生成新线程，而是使用 ThreadPool 。

Answer 3

我会更改设计以不包含任何计时器。启动时，创建 3 个线程，并在workthreadfunc1 和 workthreadfunc2 中完成的工作上放置一个循环，并在开始或结束时使用 thread.sleep 适当的时间（15 秒、1 分钟等...）环形。您可能需要在循环开始时添加一些检查，以查看是否有人试图停止该服务，或者另一个服务是否已经启动。

Answer 4

如果尚未创建线程，您可以尝试仅创建该线程。在类级别声明workerthread1并执行以下操作：

if(workerthread1 != null)
{
      workerthread1 = new thread(workerthreadfunc1);
}

Answer 5

@marr75
@zac

这两个都是很好的建议，但为什么不呢：

int x = 0; //last exec timestamp(ts)
int s = 0; //15 s ts
int m = 0; //min ts
int d = 0; //day ts
while(check for event()){ //e.g. stop service etc.
   if((x - s)>15){
      //code for ever 15 s here
      s = currentTime();
   }
   if ((x - m)>60){
      //code for every min here
      m = currentTime();
   }
   if ((x - d)> 86400)(
      //code for every day here
      d = currentTime();
   }
   sleep(5000); // or wait() w/e sleeps the thread for 15s
   x = currentTime();
}

但这假设你正在做一个相对较轻的任务
如果你正在执行一项较繁重的任务，例如 SQL 查询和插入或其他任务，请确保线程在完成后自行终止。

您可能会遇到溢出，因为您的 15 秒和分钟工作线程分别需要超过 15 秒和一分钟的时间来执行，如果这是真的，您将更快地添加线程，然后它们终止，最终导致溢出，正如 msergeant 试图说的那样，仅如果旧的工作线程已完成，则添加一个新线程。