当前位置：文江博客话题详情

多线程处理列表数据

发布于 2024-08-10 08:34:12 字数 134 浏览 1 评论 0原文

我有超过 300,000 项的清单。我当前正在对列表执行的操作是验证地址并将原始地址和更正后的地址写入指定的文件。我想做的是将列表均匀地分配给给定数量的线程，并同时对它们进行处理。谁能帮我举一个例子来说明我如何去做这样的事情？

谢谢

原文

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

傻比既视感 2024-08-17 08:34:12

如果您使用 2.0 并且该列表仅以只读方式使用（在此处理发生时不会更改），那么您可以简单地划分索引。例如 ...

public void Process(List<Item> list, int threadCount) {
  int perThread = list.Count < threadCount ? list.Count : list.Count / threadCount;
  int index = 0;
  while ( index < list.Count ) {
     int start = index;
     int count = Math.Min(perThread,list.Count-start);
     WaitCallBack del = delegate(object state) { ProcessCore(list, start, count); };
     ThreadPool.QueueUserWorkItem(del);
     index += count;
  }
}

private void ProcessCore(List<Item> list, int startIndex, int count) {
  // Do work here
}

If you're working in 2.0 and the list is only being used in a read only fashion (not being changed while this processing is occuring) then you can simply divide up the indexes. For instance ...

public void Process(List<Item> list, int threadCount) {
  int perThread = list.Count < threadCount ? list.Count : list.Count / threadCount;
  int index = 0;
  while ( index < list.Count ) {
     int start = index;
     int count = Math.Min(perThread,list.Count-start);
     WaitCallBack del = delegate(object state) { ProcessCore(list, start, count); };
     ThreadPool.QueueUserWorkItem(del);
     index += count;
  }
}

private void ProcessCore(List<Item> list, int startIndex, int count) {
  // Do work here
}

回复收藏 0 原文