Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public class BufferTest
- {
- private readonly CSPacket Packet;
- private readonly CSPacketQueue _CSQueue;
- private readonly RingBuffer<CSPacket> _Ringbuffer;
- private readonly ConcurrentQueue<CSPacket> _CCQueue;
- public BufferTest()
- {
- Packet = new CSPacket(new byte[500]);
- _CSQueue = new CSPacketQueue();
- _Ringbuffer = new RingBuffer<CSPacket>(100);
- _CCQueue = new ConcurrentQueue<CSPacket>();
- }
- [Benchmark]
- public void LockQueue()
- {
- for (int i = 0; i < 1; i++)
- {
- CSPacket res;
- _CSQueue.Enqueue(Packet);
- _CSQueue.TryDequeue(out res);
- }
- }
- [Benchmark]
- public void RingBuffer()
- {
- for (int i = 0; i < 1; i++)
- {
- CSPacket res;
- _Ringbuffer.Enqueue(Packet);
- _Ringbuffer.TryDequeue(out res);
- }
- }
- [Benchmark]
- public void CCQueue()
- {
- for (int i = 0; i < 1; i++)
- {
- CSPacket res;
- _CCQueue.Enqueue(Packet);
- _CCQueue.TryDequeue(out res);
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment