PvE/Torch
3
0
Fork 0
Code Issues 1 Pull Requests Actions Releases 21 Wiki Activity

Use thread safe queues in MtObservableCollectionBase

Browse Source
This commit is contained in:
John Gross
2019-01-25 12:36:41 -08:00
parent 6b039288d5
commit 6d29bce267
1 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
Torch/Collections/MtObservableCollectionBase.cs
View File

@@ -1,5 +1,6 @@
using System; using System;
using System.Collections; using System.Collections;
using System.Collections.Concurrent;
using System.Collections.Generic; using System.Collections.Generic;
using System.Collections.Specialized; using System.Collections.Specialized;
using System.ComponentModel; using System.ComponentModel;
@@ -123,10 +124,10 @@ namespace Torch.Collections
private readonly Timer _flushEventQueue; private readonly Timer _flushEventQueue;
private const int _eventRaiseDelay = 50; private const int _eventRaiseDelay = 50;
private readonly Queue<NotifyCollectionChangedEventArgs> _collectionEventQueue = private readonly ConcurrentQueue<NotifyCollectionChangedEventArgs> _collectionEventQueue =
new Queue<NotifyCollectionChangedEventArgs>(); new ConcurrentQueue<NotifyCollectionChangedEventArgs>();
private readonly Queue<string> _propertyEventQueue = new Queue<string>(); private readonly ConcurrentQueue<string> _propertyEventQueue = new ConcurrentQueue<string>();
private void FlushEventQueue(object data) private void FlushEventQueue(object data)
{ {
@@ -137,7 +138,8 @@ namespace Torch.Collections
// :/, but works better // :/, but works better
bool reset = _collectionEventQueue.Count > 0; bool reset = _collectionEventQueue.Count > 0;
if (reset) if (reset)
_collectionEventQueue.Clear(); while (_collectionEventQueue.Count > 0)
_collectionEventQueue.TryDequeue(out _);
else else
while (_collectionEventQueue.TryDequeue(out NotifyCollectionChangedEventArgs e)) while (_collectionEventQueue.TryDequeue(out NotifyCollectionChangedEventArgs e))
_collectionChangedEvent.Raise(this, e); _collectionChangedEvent.Raise(this, e);