Comment implémenter une file d'attente de blocage en filetage avec des limites de taille dans .NET?

La file d'attente de blocage de sécurité du thread dans le thread dans .net

Dans la scène où les files d'accès à accès multi-thread sont accessibles en même temps, la taille de la file d'attente de contrôle est essentielle pour empêcher la croissance infinie de la file d'attente. Cet article traite de la méthode de création d'une file d'attente de blocage personnalisée dans le .NET.

Une solution simple consiste à utiliser la collection comme base de la file d'attente et à utiliser

(_fullevent) pour bloquer le thread supplémentaire lorsque la file d'attente atteint le maximum spécifié (MaxSize). Lors du retrait du projet, un signal _fulLevent est publié pour permettre à l'équipe.

AutoResetEvent Cependant, en raison d'une synchronisation insuffisante, la sécurité de cette implémentation est inquiétante. La méthode d'amélioration consiste à utiliser le type de file d'attente standardisé et à utiliser l'élément synchrone pour afficher l'obstruction de la gestion.

Le code suivant montre l'implémentation de l'amélioration:

Cette réalisation fournit un mécanisme qui fournit une taille de file d'attente sûre et efficace en utilisant une structure de synchronisation intégrée. De plus, il comprend également la fonction de fermeture de la file d'attente avec élégance, permettant au lecteur de sortir proprement.

<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>

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!