c＃任務不工作，沒有他們之間的睡眠

Question

我在c＃中使用任務通過FTP在多線程中發送文件。

這裏是我的功能（文件是一個字符串列表）

Task<bool>[] result = new Task<bool>[file.Count]; 
     int j = 0; 
     foreach (string f in file) 
     { 
      result[j] = new Task<bool>(() => ftp.UploadFtp(f, "C:\\Prova\\" + f + ".txt", j)); 
      result[j].Start(); 
      j++; 

      //System.Threading.Thread.Sleep(50); 

     } 
     Task.WaitAll(result, 10000); 

和功能，這樣的程序試圖始終保存的最後一個文件上傳文件

public static bool UploadFtp(string uploadFileName, string localFileName, int i) 
    { 
     FtpWebRequest request = (FtpWebRequest)WebRequest.Create("ftp://127.0.0.1/" + uploadFileName + ".txt"); 
     //settare il percorso per il file da uplodare 
     //FtpWebRequest request = (FtpWebRequest)WebRequest.Create("ftp://desk.txt.it/"); 
     request.Method = WebRequestMethods.Ftp.UploadFile; 

     request.Credentials = new NetworkCredential("ftp_admin", ""); 
     //request.Credentials = new NetworkCredential("avio", "avio_txt"); 
     try 
     { 
      Console.WriteLine(uploadFileName); 
      Console.WriteLine(i); 
      StreamReader sourceStream = new StreamReader(localFileName); 
      byte[] fileContents = File.ReadAllBytes(localFileName); 

      sourceStream.Close(); 
      request.ContentLength = fileContents.Length; 

      Stream requestStream = request.GetRequestStream(); 
      requestStream.Write(fileContents, 0, fileContents.Length); 
      requestStream.Close(); 

      FtpWebResponse response = (FtpWebResponse)request.GetResponse(); 

      //MessageBox.Show("Upload File Complete, status {0}", response.StatusDescription); 

      response.Close(); 
      return true; 
     } 
     catch (Exception e) 
     { 
      return false; 
     } 

    } 

列表，但如果我添加睡眠（50），則會正確上傳文件。 看來，程序啓動4任務做同樣的工作（保存最後一個文件）只有當我不使用睡眠，但我不明白爲什麼，我不知道如何解決問題。

有人可以幫助我嗎？謝謝

Answer 1

看看你的代碼：當它執行

int j = 0; 
foreach (string f in file) 
{ 
    result[j] = new Task<bool>(() => ftp.UploadFtp(f, "C:\\Prova\\" + f + ".txt", j)); 
    result[j].Start(); 
    j++; 
} 

Lambda表達式使用的j的電流值。因此，如果在之後任務開始j增加，您將錯過您想要的值。

在C＃4中，您遇到與f相同的問題 - 但這已在C＃5中修復。有關更多詳細信息，請參閱Eric Lippert的博文"Closing over the loop variable considered harmful"。

最小的解決辦法很繁瑣：

int j = 0; 
foreach (string f in file) 
{ 
    int copyJ = j; 
    string copyF = f; 
    result[j] = new Task<bool>(
     () => ftp.UploadFtp(copyF, "C:\\Prova\\" + copyF + ".txt", copyJ)); 
    result[j].Start(); 
    j++; 
} 

現在什麼都不會改變copyJ和copyF - 你會得到一個單獨的變量作爲一個在每次循環抓獲。在C＃5中，您不需要copyF，而只需使用f。

...但我也建議使用Task.Factory.StartNew()（或.NET中的Task.Run）或只是Parallel.For。