进程为什么会丢失线程
本文关键字:线程 为什么 进程 | 更新日期: 2023-09-27 18:01:36
下面是一些永久生成guid的代码。我写它是为了学习线程。在这里你会注意到我有一个锁在我生成guid的地方并让它们排队,尽管ConcurrentQueue是线程安全的。这是因为我的实际代码将需要使用NHibernate,所以我必须确保只有一个线程可以填充队列。
当我在任务管理器中监视此代码时,我注意到该进程将线程数从18(在我的机器上)减少到14,但不少于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());
}
}
}
您正在使用。net的ThreadPool,因此。net/windows根据等待处理的工作量来管理线程的数量。
当我在Task中监视此代码时经理,我注意到进度下降了线程数从18(在我的机器)到14,但不能少于。这是因为我的代码不好?
这并不表示有问题。14仍然很高,除非你有一个16核的cpu。
线程池将尝试调整并使用尽可能少的线程完成工作。
当线程数量显著增加时,您应该开始担心了。