相同方法中的ThreadPool异步线程
|
我有一个关于ThreadPool使用的问题。
在我运行下面的简单代码之后。我得到结果：
编号：6-> A
ID：13-> A
编号：6-> 2A
ID：12-> A
ID：13-> 2A
ID：15-> A
编号：6-> 3A
ID：12-> 2A
ID：14-> A
ID：13-> 3A
（继续...）
这是我的代码：
static void Main(string[] args)
{
Program p = new Program();
p.Start();
Console.ReadLine();
}
private void Start()
{
System.Timers.Timer senderTimer;
senderTimer = new System.Timers.Timer();
senderTimer.Elapsed += new System.Timers.ElapsedEventHandler(SenderTimer);
senderTimer.Interval = 500;
senderTimer.Enabled = true;
}
private void SenderTimer(object Source, ElapsedEventArgs e)
{
ThreadPool.QueueUserWorkItem(new WaitCallback(Foo));
}
private void Foo(object state)
{
string[] array = new string[] { \"A\", \"2A\", \"3A\", \"4A\", \"5A\", \"6A\", \"7A\", \"8A\", \"9A\", \"10A\" };
for (int i = 0; i < array.Length; i++)
{
Trace.WriteLine(\"ID : \" + Thread.CurrentThread.GetHashCode() + \" --> \" + array[i]);
Thread.Sleep(1000); // Here I have a DB Operation, so i make it sleep
}
}
没有找到相关结果
已邀请:
2 个回复
惜堡沁戚
string[] array = new string[] { \"A\", \"2A\", \"3A\", \"4A\", \"5A\", \"6A\", \"7A\", \"8A\", \"9A\", \"10A\" }; var results = array.AsParallel().Select((item, i) => new { Index = i, Result = ProcessItem(item) }) .OrderBy(x => x.Index) .Select(i=>i.Result) .ToList();抚驰
，它将返回数组中尚未处理的下一项。然后，在您的函数中，调用类似lock(this) { string nextItem = GetNextItemToProcess(); Trace.WriteLine(\"ID : \" + Thread.CurrentThread.GetHashCode() + \" --> \" + nextItem ); }