如何正确地每分钟执行一次线程？

Question

这个问题分为两部分。 我有一个控制台应用程序，它从多个服务器获取信息并将此信息保存到数据库。为了使这同时执行，我使用了线程。我试图让这个执行每分钟自动执行一次。

搜索stackoverflow我发现这可以工作：

   var timer = new System.Threading.Timer((e) =>
        {
            var models = ServerHandler.GetServerModels();

            foreach (var m in models)
            {
                ServerHandler.MakeThreads(m);
            }

            Console.WriteLine("Running...");
            Console.WriteLine("Press 'X' to exit or close the window, i : " + i);

            i++;


        }, null, 0, TimeSpan.FromMinutes(1).Seconds);

但是这并没有按预期工作，它只执行一次。如果我更改为例如：

TimeSpan.FromMinutes(0.5).Seconds

或者：

TimeSpan.FromSeconds(30).Seconds

然后就可以了。 我做错了什么？

本题的第二部分：

当这实际上像我上​​面展示的那样工作时，会发生其他事情。 该进程连续运行，并在 474 个线程后崩溃并说系统内存不足。

我尝试为此使用线程睡眠，但是当我这样做时，它在运行一次后停止执行。

如果可能有帮助，请包括以下内容：

public static void MakeThreads(ServerModel model)
{
    Thread thread = new Thread(() => SaveServerInfo(model));
    thread.Start();
    //Thread.Sleep(1);
    //thread.Join();

}

我怎样才能做到这一点？

Answer 1

在您的第一个问题中，使用 .Seconds 只会返回秒值，但您将分钟值定义为 0.5，因此秒将始终为零。

如果要返回需要使用 TotalSeconds 的秒数

TimeSpan.FromMinutes(0.5).TotalSeconds

在您使用的时间跨度内，您应该定义毫秒。因此，您将获得大量线程，因为它每 30 毫秒而不是每 30000 毫秒运行一次。

所以用

TimeSpan.FromMinutes(0.5).TotalMilliseconds

或者我总是觉得更容易的事情

(int)(1000 * 60 * 0.5)  // Then you just replace the 0.5 with the number of seconds. 

Answer 2

基本上，计时器完全按照它应该做的事情：每 0.5 秒运行一次代码。 :) 在你的情况下，这是一个问题......

（请检查语法错误等，我在记事本中写这个）

长期解决方案

您的问题似乎是您无法控制线程。以下是我的解决方法：（这个较长的解决方案显示了它或多或少的工作原理）

while (true)
{    
    // we want to run it again in 0.5 seconds.
    DateTime start = DateTime.UtcNow.AddSeconds(0.5); 

    Thread[] threads = new Thread[models.Count];
    for (int i=0; i<models.Count; ++i)
    {
        threads[i] = new Thread((a) => SaveServerInfo((ServerModel)a));
        threads[i].Start(models[i]);
    }

    for (int i=0; i<models.Count; ++i)
    {
        threads[i].Join();
    }

    DateTime current = DateTime.UtcNow;
    if (current < start)
    {
        Thread.Sleep(start.Subtract(current));
    }

}

短解决方案

但是，这也可能会给您带来问题：您可能会产生太多线程。这可以通过一种称为线程池的机制来解决。事实证明，有一个简单的方法可以解决这个问题：

static void DoStuff(string s)
{
    // change to a value > 0.5 as well to ensure everything works
    Thread.Sleep(TimeSpan.FromSeconds(0.1)); 
    Console.WriteLine(s);
}

static void Handle(List<string> models)
{
    while (true)
    {
        // we want to run it again in 0.5 seconds.
        DateTime start = DateTime.UtcNow.AddSeconds(0.5);

        Parallel.ForEach(models, (a) => DoStuff(a));
        DateTime current = DateTime.UtcNow;
        if (current < start)
        {
            Thread.Sleep(start.Subtract(current));
        }
    }
}

static void Main(string[] args)
{
    List<string> models = new List<string>();
    for (int i = 0; i < 10; ++i)
    {
        models.Add(i.ToString());
    }

    Handle(models);

}