c# - Async、Await、ManualResetEvents を適切に使用して無限 while ループを制御する方法

Question

だから私がここでやろうとしていることは次のとおりです。

1. キューが空でない場合は、エンジンをループさせてオブジェクトを処理します。
2. キューが空の場合、manualresetevent を呼び出してスレッドをスリープ状態にします。
3. アイテムが追加され、ループがアクティブでない場合、manualresetevent を設定します。
4. 高速化するために、リストから最大 5 つの項目を選択し、非同期で操作を実行して、すべてが完了するのを待ちます。

問題：

1. AddToUpdateQueueMethod への新しい呼び出しが呼び出されるとすぐに、2 つのリストの clear メソッドが呼び出されます。
2. 私の頭の中で Task.WhenAll(tasks) を待っているので、スレッドはその完了を待ってから先に進む必要があるため、リストのクリアは Task.WhenAll(tasks) が戻った後にのみ呼び出す必要があります。

ここで何が欠けているのか、これを達成するためのより良い方法は何ですか.

    public async Task ThumbnailUpdaterEngine()
    {
        int count;
        List<Task<bool>> tasks = new List<Task<bool>>();
        List<Content> candidateContents = new List<Content>();
        while (true)
        {

            for (int i = 0; i < 5; i++)
            {
                Content nextContent = GetNextFromInternalQueue();
                if (nextContent == null)
                    break;
                else
                    candidateContents.Add(nextContent);

            }

            foreach (var candidateContent in candidateContents)
            {
                foreach (var provider in interactionProviders)
                {
                    if (provider.IsServiceSupported(candidateContent.ServiceType))
                    {
                        Task<bool> task = provider.UpdateThumbnail(candidateContent);
                        tasks.Add(task);
                        break;
                    }
                }
            }
            var results = await Task.WhenAll(tasks);
            tasks.Clear();
            foreach (var candidateContent in candidateContents)
            {
                if (candidateContent.ThumbnailLink != null && !candidateContent.ThumbnailLink.Equals(candidateContent.FileIconLink, StringComparison.CurrentCultureIgnoreCase))
                {
                    Task<bool> task = DownloadAndUpdateThumbnailCache(candidateContent);
                    tasks.Add(task);
                }
            }
            await Task.WhenAll(tasks);

            //Clean up for next time the loop comes in.
            tasks.Clear();
            candidateContents.Clear();

            lock (syncObject)
            {
                count = internalQueue.Count;
                if (count == 0)
                {
                    isQueueControllerRunning = false;
                    monitorEvent.Reset();
                }
            }
            await Task.Run(() => monitorEvent.WaitOne());


        }
    }

    private Content GetNextFromInternalQueue()
    {
        lock (syncObject)
        {
            Content nextContent = null;
            if (internalQueue.Count > 0)
            {
                nextContent = internalQueue[0];
                internalQueue.Remove(nextContent);
            }
            return nextContent;
        }
    }

    public void AddToUpdateQueue(Content content)
    {
        lock (syncObject)
        {
            internalQueue.Add(content);
            if (!isQueueControllerRunning)
            {
                isQueueControllerRunning = true;
                monitorEvent.Set();
            }
        }
    }