首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >问答首页 >从列表中选择每1000项,并将其传递给一个方法

从列表中选择每1000项,并将其传递给一个方法
EN

Stack Overflow用户
提问于 2017-03-21 06:38:40
回答 2查看 895关注 0票数 1

我有一个列表,目前我们一次只将一个项目传递给另一个方法

代码语言:javascript
复制
foreach (var contact in tracker.Parse())

基本上,我们从Azure Blob存储中选择联系人并将其导入Dynamics CRM。tracker.Parse()返回的是联系人列表。

我希望每隔1000次选择一次,然后等待它们在另一种方法中完成,然后再传入下一个1000。

需要关于如何做到这一点的指导。

感谢您的帮助!

EN

回答 2

Stack Overflow用户

发布于 2017-03-21 07:44:51

将数据源中的数据分组为所需的组大小,并对其进行处理。

使用Linq可以通过SelectGroupBy扩展来实现

代码语言:javascript
复制
int groupSize = 1000;

//Batch the data
var batches = tracker.Parse()
  .Select((contact, index) => new { contact, index })
  .GroupBy(_ => _.index / groupSize, _ => _.contact);

//Process the batches.
foreach (var batch in batches) {
    //Each batch would be IEnumerable<TContact>
    ProcessBatch(batch);
}

如果需要,可以将其转换为可重用的泛型方法

代码语言:javascript
复制
public static void ProcessInBatches<TItem>(this IEnumerble<TItem> items, int batchSize, Action<IEnumerable<TItem>> processBatch) {

    //Batch the data
    var batches = items
      .Select((item, index) => new { item, index })
      .GroupBy(_ => _.index / batchSize, _ => _.item);

    //Process the batches.
    foreach (var batch in batches) {
        //Each batch would be IEnumerable<TItem>
        processBatch(batch);
    }
}
票数 3
EN

Stack Overflow用户

发布于 2017-03-21 06:52:29

也许就像这样..。

代码语言:javascript
复制
static void Main()
{
    const int batchSize = 1000;

    // Populate array with 5841 items of data
    var lotsOfItems = new List<int>();
    for (int i = 0; i < 5841; i++)
    {
        lotsOfItems.Add(i);
    }

    // Process items in batches, waiting for each batch to complete before the next
    int indexOfLastItemTaken = 0;
    while (indexOfLastItemTaken < lotsOfItems.Count - 1)
    {
        var itemsTaken = lotsOfItems.Skip(indexOfLastItemTaken).Take(batchSize).ToList();
        ProcessItems(itemsTaken);
        indexOfLastItemTaken += itemsTaken.Count();
    }

    Console.Write("Done. Press any key to quit...");
    Console.ReadKey();
}

static void ProcessItems(IEnumerable<int> input)
{
    // do something with input
    Console.WriteLine(new string('-', 15));
    Console.WriteLine($"Processing a new batch of {input.Count()} items:");
    Console.WriteLine(string.Join(",", input));
}
票数 0
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/42915251

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档