将多个参数传递给任务

Question

我希望将两个BlockingCollection<>传递给任务。我试图把它们放在一个对象数组中并传递它们，但它不起作用。谁能帮我这个？在那里我试图值传递的代码如下记载：

var lineHolders = new[] 
{ 
    new BlockingCollection<string>(linesCapacity), 
    new BlockingCollection<string>(linesCapacity), 
    new BlockingCollection<string>(linesCapacity), 
    new BlockingCollection<string>(linesCapacity) 
}; 

var chunksHolder = new[] 
{ 
    new BlockingCollection<List<BsonDocument>>(chunksCapacity), 
    new BlockingCollection<List<BsonDocument>>(chunksCapacity) 
}; 

for (var processors = 0; processors < 16; processors++) 
{ 
     var myLineHolder = lineHolders[processors%lineHolders.Length]; 
     var myChunkHolder = chunksHolder[processors%chunksHolder.Length]; 
     processorTaskArray[processors] = Task.Factory.StartNew((arg) => 
     { 
      var lines = (BlockingCollection<string>) arg[0]; // compiler generates error here 
      var chunks = (BlockingCollection<List<BsonDocument>>) arg[1]; // compiler generates error here 

      // perform my work... 


     }, 
     new object [] 
     { 
      myLineHolder, 
      myChunkHolder 
     }); 
} 

Answer 1

您使用的是following超载StartNew的：

public Task StartNew(
    Action<Object> action, 
    Object state 
) 

因为它只是不能应用索引上的对象它。投它，它会正常工作。

for (var processors = 0; processors < 16; processors++) 
     { 
      var myLineHolder = lineHolders[processors % lineHolders.Length]; 
      var myChunkHolder = chunksHolder[processors % chunksHolder.Length]; 
      processorTaskArray[processors] = Task.Factory.StartNew((arg) => 
      { 
       var properArg = (object[]) arg; 
       var lines = (BlockingCollection<string>) properArg[0]; // compiler generates error here 
       var chunks = (BlockingCollection<List<BsonDocument>>) properArg[1]; // compiler generates error here 

       // perform my work... 

      }, 
      new object[] 
       { 
        myLineHolder, 
        myChunkHolder 
       }); 
     }