2

有一个案例，应用系统需要每1分钟向在线用户发布消息，代码是使用multithead任务读取消息列表。但是程序运行不正确，会抛出一个 index out of range 异常。请有人可以提出任何建议，谢谢。

private Timer taskTimer;
private static readonly object _locker = new object();
private static IList<Message> _messages = null;

private void OnTimerElapsed(object sender)
{
    var msgModel = new MessageModel();
    _messages = msgModel.GetMessageList();
    var msgCount = _messages.Count();

    Task[] _tasks = new Task[msgCount];
    for (int i = 0; i < msgCount; i++)
    {
        if (i < msgCount)
        {
            _tasks[i] = Task.Factory.StartNew(() =>
            {
                lock (_locker)
                {
                    PushMessage(i);
                }
            });
        }
    }

    //waiting all task finished
    while (_tasks.Any(t => !t.IsCompleted)) { }
}

private void PushMessage(int i)
{          
    var msg = _messages[i];         //it will throw an exception here...
    //send message to on line users.
    SendToOnlineUsers(msg);
}

Error:
Index was out of range. Must be non-negative and less than the size of the collection.

StackTrace Details:
   at System.ThrowHelper.ThrowArgumentOutOfRangeException()
   at System.Collections.Generic.List`1.get_Item(Int32 index)
   at WebIM.Hubs.BackgroudPushServiceTimer.PushMessage(Int32 i) in ...
   at WebIM.Hubs.BackgroudPushServiceTimer.<>c__DisplayClass6.<OnTimerElapsed>b__2() in ...
   at System.Threading.Tasks.Task.InnerInvoke()
   at System.Threading.Tasks.Task.Execute()

如果消息数为 4，并且 PushMessage 函数中的索引也是 4，则超出范围。

4

1 回答 1

5

问题是您正在捕获i，一个其值随时间变化的变量。您可以通过在循环内制作本地副本来修复它：

for (int i = 0; i < msgCount; i++)
{
    int copyOfI = i;
    if (i < msgCount)
    {
        _tasks[i] = Task.Factory.StartNew(() =>
        {
            lock (_locker)
            {
                PushMessage(copyOfI);
            }
        });
    }
}

也就是说，我怀疑有更简洁的方法来处理这个问题——尤其是当你创建几个都使用同一个锁的任务时。您实际上并没有在这里实现任何并发性，然后您正在等待一切完成 - 那么您为什么要解决所有这些麻烦呢？

您还应该将Task.WhenAll/Task.WaitAll视为等待任务完成的更有效的方式。

编辑：如果您可以并行执行此操作，请考虑使用Parallel.FororParallel.ForEach代替。

于 2013-06-26T09:38:52.603 回答