csharp ConcurrentQueue使用锁在旧的.NET项目中使用（如在Unity3D中）

Posted 2021-05-12

using System;
using System.Collections.Generic;

namespace KanameExtensions {
    public class ConcurrentQueue<T> {
        //private vars
        private readonly object syncLock = new object();
        private Queue<T> rqueue;

        //constructors
        public ConcurrentQueue() {
            rqueue = new Queue<T>();
        }

        public ConcurrentQueue(IEnumerable<T> collection) {
            rqueue = new Queue<T>(collection);
        }

        public ConcurrentQueue(int capacity) {
            rqueue = new Queue<T>(capacity);
        }

        //properties
        public int Count {
            get {
                lock (syncLock) {
                    return rqueue.Count;
                }
            }
        }

        //methods
        public void Clear() {
            lock (syncLock) {
                rqueue.Clear();
            }
        }

        public bool Contains(T obj) {
            lock (syncLock) {
                return rqueue.Contains(obj);
            }
        }

        public void CopyTo(T[] array, int index) {
            lock (syncLock) {
                rqueue.CopyTo(array, index);
            }
        }

        public T Dequeue() {
            lock (syncLock) {
                return rqueue.Dequeue();
            }
        }

        public void Enqueue(T obj) {
            lock (syncLock) {
                rqueue.Enqueue(obj);
            }
        }

        public bool Equals(T obj) {
            lock (syncLock) {
                return rqueue.Equals(obj);
            }
        }

        public Queue<T>.Enumerator GetEnumerator() {
            lock (syncLock) {
                return rqueue.GetEnumerator();
            }
        }

        public new virtual int GetHashCode() {
            lock (syncLock) {
                return rqueue.GetHashCode();
            }
        }

        public new Type GetType() {
            lock (syncLock) {
                return rqueue.GetType();
            }
        }

        public T Peek() {
            lock (syncLock) {
                return rqueue.Peek();
            }
        }

        public T[] ToArray() {
            lock (syncLock) {
                return rqueue.ToArray();
            }
        }

        public new virtual string ToString() {
            lock (syncLock) {
                return rqueue.ToString();
            }
        }

        public void TrimExcess() {
            lock (syncLock) {
                rqueue.TrimExcess();
            }
        }
    }
}