При запросе Queue.Synchonized вы получаете SynchronizedQueue взамен, который использует lock очень минимально вокруг вызовов Enqueue и Dequeue во внутренней очереди. Следовательно, производительность должна быть такой же, как при использовании Queue и управлении блокировкой для Enqueue и Dequeue с вашим собственным lock.
Вы действительно воображаете вещи - они должны быть одинаковыми.
Обновление
На самом деле существует тот факт, что при использовании SynchronizedQueue вы добавляете слой косвенности, поскольку вам нужно пройти через методы-оболочки, чтобы попасть во внутреннюю очередь, которой он управляет. Во всяком случае, это должно очень замедлить процесс, поскольку у вас есть дополнительный кадр в стеке, которым нужно управлять для каждого вызова. Бог знает, отменяет ли это встраивание все же. Что бы - это минимально .
Обновление 2
Сейчас я проверил это, и как и предсказывалось в моем предыдущем обновлении:
«Queue.Synchronized» медленнее, чем «Queue + lock»
Я провел однопоточный тест, так как оба они используют одну и ту же технику блокировки (т. Е. lock), поэтому проверка чистых служебных данных по "прямой линии" кажется разумной.
Мой тест показал следующие результаты для Release build:
Iterations :10,000,000
Queue+Lock :539.14ms
Queue+Lock :540.55ms
Queue+Lock :539.46ms
Queue+Lock :540.46ms
Queue+Lock :539.75ms
SynchonizedQueue:578.67ms
SynchonizedQueue:585.04ms
SynchonizedQueue:580.22ms
SynchonizedQueue:578.35ms
SynchonizedQueue:578.57ms
Используя следующий код:
private readonly object _syncObj = new object();
[Test]
public object measure_queue_locking_performance()
{
const int TestIterations = 5;
const int Iterations = (10 * 1000 * 1000);
Action<string, Action> time = (name, test) =>
{
for (int i = 0; i < TestIterations; i++)
{
TimeSpan elapsed = TimeTest(test, Iterations);
Console.WriteLine("{0}:{1:F2}ms", name, elapsed.TotalMilliseconds);
}
};
object itemOut, itemIn = new object();
Queue queue = new Queue();
Queue syncQueue = Queue.Synchronized(queue);
Action test1 = () =>
{
lock (_syncObj) queue.Enqueue(itemIn);
lock (_syncObj) itemOut = queue.Dequeue();
};
Action test2 = () =>
{
syncQueue.Enqueue(itemIn);
itemOut = syncQueue.Dequeue();
};
Console.WriteLine("Iterations:{0:0,0}\r\n", Iterations);
time("Queue+Lock", test1);
time("SynchonizedQueue", test2);
return itemOut;
}
[SuppressMessage("Microsoft.Reliability", "CA2001:AvoidCallingProblematicMethods", MessageId = "System.GC.Collect")]
private static TimeSpan TimeTest(Action action, int iterations)
{
Action gc = () =>
{
GC.Collect();
GC.WaitForFullGCComplete();
};
Action empty = () => { };
Stopwatch stopwatch1 = Stopwatch.StartNew();
for (int j = 0; j < iterations; j++)
{
empty();
}
TimeSpan loopElapsed = stopwatch1.Elapsed;
gc();
action(); //JIT
action(); //Optimize
Stopwatch stopwatch2 = Stopwatch.StartNew();
for (int j = 0; j < iterations; j++) action();
gc();
TimeSpan testElapsed = stopwatch2.Elapsed;
return (testElapsed - loopElapsed);
}