C#多线程-上传到FTP服务器

本文关键字：FTP 服务器 多线程 | 更新日期: 2023-09-27 17:58:21

在C#程序中实现多线程时，我想寻求您的帮助。

该程序旨在将10000多个文件上传到ftp服务器。我计划至少实现10个线程，以提高进程的速度。

有了这个，这就是我的代码行：

我已经初始化了10个线程：

public ThreadStart[] threadstart = new ThreadStart[10];
public Thread[] thread = new Thread[10];

我的计划是将一个文件分配给一个线程，如下所示：

file 1 > thread 1
file 2 > thread 2
file 3 > thread 3
.
.
.
file 10 > thread 10
file 11 > thread 1
.
.
.

因此，我有以下内容：

foreach (string file in files)
{
     loop++;
     threadstart[loop] = new ThreadStart(() => ftp.uploadToFTP(uploadPath + @"/" + Path.GetFileName(file), file));
     thread[loop] = new Thread(threadstart[loop]);
     thread[loop].Start();
     if (loop == 9)
     {
         loop = 0;
     }                          
}

将文件传递到各自线程的过程正在进行。我的问题是线程的起始部分重叠。

异常的一个例子是，当线程1正在运行时，会向它传递一个文件。由于线程1尚未成功完成，它会返回一个错误，然后会向它发送一个新参数。其他线程也是如此。

实现这一点的最佳方式是什么？

如有任何反馈，我们将不胜感激。谢谢！：）

C#多线程-上传到FTP服务器

使用异步等待，只需向其中传递一个文件数组：

private static async void TestFtpAsync(string userName, string password, string ftpBaseUri,
      IEnumerable<string> fileNames)
    {
      var tasks = new List<Task<byte[]>>();
      foreach (var fileInfo in fileNames.Select(fileName => new FileInfo(fileName)))
      {
        using (var webClient = new WebClient())
        {
          webClient.Credentials = new NetworkCredential(userName, password);
          tasks.Add(webClient.UploadFileTaskAsync(ftpBaseUri + fileInfo.Name, fileInfo.FullName));
        }
      }
      Console.WriteLine("Uploading...");
      foreach (var task in tasks)
      {
        try
        {
          await task;
          Console.WriteLine("Success");
        }
        catch (Exception ex)
        {
          Console.WriteLine(ex.ToString());
        }
      }
    }

然后这样称呼它：

  const string userName = "username";
  const string password = "password";
  const string ftpBaseUri = "ftp://192.168.1.1/";
  var fileNames = new[] { @"d:'file0.txt", @"d:'file1.txt", @"d:'file2.txt" };
  TestFtpAsync(userName, password, ftpBaseUri, fileNames);

为什么这么难？.net已经有一个名为ThreadPool的类。您可以直接使用它，它自己管理线程。你的代码是这样的：

 static void DoSomething(object n)
    {
        Console.WriteLine(n);
        Thread.Sleep(10);
    }
    static void Main(string[] args)
    {
        ThreadPool.SetMaxThreads(20, 10);
        for (int x = 0; x < 30; x++)
        {
            ThreadPool.QueueUserWorkItem(new WaitCallback(DoSomething), x);
        }
        Console.Read();
    }
相关文章：