Bagaimana untuk melaksanakan giliran menyekat benang dengan had saiz dalam .net?

Giliran menghalang keselamatan benang dalam benang dalam .net

Di tempat kejadian di mana antrian akses berbilang yang diakses pada masa yang sama, saiz barisan kawalan adalah penting untuk mencegah pertumbuhan tak terhingga barisan. Artikel ini membincangkan kaedah membuat giliran menyekat tersuai dalam .NET.

Penyelesaian mudah adalah menggunakan koleksi sebagai asas barisan, dan gunakan

(_fulleVent) untuk menyekat benang tambahan apabila barisan mencapai maksimum yang ditentukan (maxSize). Apabila mengeluarkan projek, isyarat _fullevent dikeluarkan untuk membolehkan pasukan.

Walau bagaimanapun, disebabkan oleh penyegerakan yang tidak mencukupi, keselamatan pelaksanaan ini membimbangkan. Kaedah penambahbaikan adalah menggunakan jenis giliran piawai dan menggunakan elemen segerak untuk memaparkan halangan pengurusan. AutoResetEvent

Kod berikut menunjukkan pelaksanaan peningkatan:

Kesedaran ini menyediakan mekanisme yang menyediakan saiz giliran yang selamat dan cekap dengan menggunakan struktur penyegerakan yang terbina dalam. Di samping itu, ia juga termasuk fungsi menutup barisan dengan elegan, membolehkan pembaca keluar dengan bersih.

<code class="language-csharp">class SizeQueue<T>
{
    private readonly Queue<T> queue = new Queue<T>();
    private readonly int maxSize;

    public SizeQueue(int maxSize) { this.maxSize = maxSize; }

    public void Enqueue(T item)
    {
        lock (queue)
        {
            while (queue.Count >= maxSize)
            {
                Monitor.Wait(queue);
            }
            queue.Enqueue(item);
            if (queue.Count == 1)
            {
                // 唤醒任何被阻塞的出队操作
                Monitor.PulseAll(queue);
            }
        }
    }

    public T Dequeue()
    {
        lock (queue)
        {
            while (queue.Count == 0)
            {
                Monitor.Wait(queue);
            }
            T item = queue.Dequeue();
            if (queue.Count == maxSize - 1)
            {
                // 唤醒任何被阻塞的入队操作
                Monitor.PulseAll(queue);
            }
            return item;
        }
    }
}</code>

Atas ialah kandungan terperinci Bagaimana untuk melaksanakan giliran menyekat benang dengan had saiz dalam .net?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!