Warum erstellt Parallel.Foreach endlose Threads?

Der folgende Code erstellt weiterhin Threads, auch wenn die Warteschlange leer ist. Bis schließlich eine OutOfMemory-Ausnahme auftritt. Wenn ich die Parallel.ForEach durch eine reguläre foreach ersetze, passiert dies nicht. Kennt jemand Gründe, warum dies passieren kann?

public delegate void DataChangedDelegate(DataItem obj);

public class Consumer
{
    public DataChangedDelegate OnCustomerChanged;
    public DataChangedDelegate OnOrdersChanged;

    private CancellationTokenSource cts;
    private CancellationToken ct;
    private BlockingCollection<DataItem> queue;

    public Consumer(BlockingCollection<DataItem> queue) {
        this.queue = queue;
        Start();
    }

    private void Start() {
        cts = new CancellationTokenSource();
        ct = cts.Token;
        Task.Factory.StartNew(() => DoWork(), ct);
    }

    private void DoWork() {

        Parallel.ForEach(queue.GetConsumingPartitioner(), item => {
            if (item.DataType == DataTypes.Customer) {
                OnCustomerChanged(item);
            } else if(item.DataType == DataTypes.Order) {
                OnOrdersChanged(item);
            }
        });
    }
}

Antworten auf die Frage(3)

Ihre Antwort auf die Frage