为什么进程会丢失线程？答案

【问题标题】：Why does the process lose threads?为什么进程会丢失线程？
【发布时间】：2011-07-08 07:06:34
【问题描述】：

这是一些永久生成 GUID 的代码。我写它是为了了解线程。在其中您会注意到，即使 ConcurrentQueue 是线程安全的，我也会在生成 GUID 并将它们排入队列的位置锁定。这是因为我的实际代码需要使用 NHibernate，所以我必须确保只有一个线程可以填充队列。

当我在任务管理器中监视此代码时，我注意到该进程将线程数从 18（在我的机器上）减少到 14，但不少于。这是因为我的代码不好吗？

如果他们认为合适，是否有人可以重构它？我喜欢更短的代码。

class Program
{
    ConcurrentNewsBreaker Breaker;

    static void Main(string[] args)
    {
        new Program().Execute();

        Console.Read();
    }

    public void Execute()
    {
        Breaker = new ConcurrentNewsBreaker();
        QueueSome();
    }

    public void QueueSome()
    {
        ThreadPool.QueueUserWorkItem(DoExecute);
    }

    public void DoExecute(Object State)
    {
        String Id = Breaker.Pop();
        Console.WriteLine(String.Format("- {0} {1}", Thread.CurrentThread.ManagedThreadId, Breaker.Pop()));

        if (Breaker.Any())
            QueueSome();
        else
            Console.WriteLine(String.Format("- {0} XXXX ", Thread.CurrentThread.ManagedThreadId));            
    }
}


public class ConcurrentNewsBreaker
{
    static readonly Object LockObject = new Object();

    ConcurrentQueue<String> Store = new ConcurrentQueue<String>();

    public String Pop()
    {
        String Result = null;
        if (Any())
            Store.TryDequeue(out Result);
        return Result;
    }

    public Boolean Any()
    {
        if (!Store.Any())
        {
            Task FillTask = new Task(FillupTheQueue, Store);
            FillTask.Start();
            FillTask.Wait();
        }

        return Store.Any();
    }

    private void FillupTheQueue(Object StoreObject)
    {
        ConcurrentQueue<String> Store = StoreObject as ConcurrentQueue<String>;
        lock(LockObject)
        {
            for(Int32 i = 0; i < 100; i++)
                Store.Enqueue(Guid.NewGuid().ToString());            
        }
    }
}

【问题讨论】：

我的电脑有 2 个核心。有没有办法告诉 ThreadPool 有多少线程专用于我的进程？
你有几个核心？在这里使用更多线程有什么帮助？请注意，您的锁定意味着此处一次只能使用 1 个线程...
@Am - 线程永远不会“专用于进程”。线程是每个进程的。
Task FillTask = new Task(FillupTheQueue, Store); FillTask.Start(); FillTask.Wait(); == FillupTheQueue(Store) - 除了阅读起来更复杂，引入了不必要的线程，需要将 Store 转换回 ConcurrentQueue<String>...
@Am：您可以设置最小（和最大）线程数，但不建议这样做。

标签： c# .net multithreading concurrency thread-safety

【解决方案1】：

您正在使用 .NET 的 ThreadPool，因此 .NET/Windows 根据等待处理的工作量来管理线程数。

【讨论】：

除了使用 int 而不是 Int32 之类的小事之外，我没有看到任何需要削减的主要领域。对不起
好的，我很高兴你这么认为。谢谢:)

【解决方案2】：

当我在 Task 中监控这段代码时经理，我注意到流程下降了线程数从 18（在我的机）到 14 但不少于。这是因为我的代码不好？

这并不表示有问题。 14 仍然很高，除非你有 16 核 CPU。

线程池将尝试调整并使用尽可能少的线程来完成工作。

当线程数显着上升时，你应该开始担心了。

【讨论】：