如何正確執行線程每分鐘？

Question

這個問題分兩部分。 我有一個控制檯應用程序，它從幾臺服務器獲取信息並將此信息保存到數據庫。爲了enabel這執行simultaniously我已經使用線程。我正在嘗試每分鐘自動執行一次該執行。

搜索計算器我發現，這可能是工作：

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將僅返回秒值，但您將分鐘值定義爲.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); 

}