c# – 代码工作但似乎同步运行而不是异步

概述static void Main(string[] args){ // do async method for each stock in the list Task<IEnumerable<string>> symbols = Helper.getStockSymbols("amex", 0); List<Task> tasks = new List<Task>();

static voID Main(string[] args){    // do async method for each stock in the List    Task<IEnumerable<string>> symbols = Helper.getStockSymbols("amex",0);    List<Task> tasks = new List<Task>();    try    {        for (int i = 0; i < symbols.Result.Count(); i++)        {            if (i < symbols.Result.Count())            {                string symbol = symbols.Result.ElementAtOrDefault(i);                Task t = Task.Run(() => getCalculationsDataAsync(symbol,"amex"));                tasks.Add(t);                Task e = t.ContinueWith((d) => getThreadStatus(tasks));            }        }        // don't exit until they choose to        while (args.FirstOrDefault() != "exit")        {            // do nothing        }    }    catch (Exception ex)    {        Console.Writeline(ex.Message);    }}public static voID getThreadStatus(List<Task> taskList){    int count = 0;    foreach (Task t in taskList)    {        if (t.Status == TaskStatus.Running)        {            count += 1;        }    }    Console.Writeline(count + " threads are running.");}public static async Task getCalculationsDataAsync(string symbol,string market){    // do calculation here}

我在我的代码中尝试做的是为列表中的每个库存运行一个新任务,并同时运行它们.我有一个4核处理器,我相信这意味着我一次只能运行4个任务.我尝试通过插入您在我的代码中看到的continuewith方法来测试运行的任务数量,该方法将告诉我正在运行的任务数量.当我运行此代码时,它告诉我0个任务正在运行,所以我的问题是：

>如何通过在同一时间运行这些任务来完成我的目标？
>为什么告诉我0个任务正在运行？我只能假设这是因为当前任务已经完成,如果任务一个接一个地运行,它还没有启动新任务.

解决方法 我不确定你为什么看不到任何任务在运行.你确定你的Task.Run()被击中了吗？也就是说我是< symbols.Result.Count()满意吗？ 无论如何,让我们尝试实现您想要的.首先,不,这是不正确的,因为你的机器有四个物理核心/’线程’,你可以使用最多四个线程.这些都不是一回事.关于此主题的谷歌将以如此方式提供大量信息. 基本上以您的方式启动线程将在线程池上启动后台线程,并且此线程池可以保存/管理多个线程,请参阅 Threading in C# by J. Albahari以获取更多信息.每当你启动一个线程时,花费几百微秒来组织一些新的私有局部变量栈.每个线程也消耗(默认情况下)大约1 MB的内存.线程池通过共享和回收线程来减少这些开销,允许在非常精细的级别上应用多线程而不会降低性能.当利用多核处理器以“分而治之”的方式并行执行计算密集型代码时,这非常有用.

线程池还会限制它将同时运行的工作线程总数.过多的活动线程会对管理负担限制 *** 作系统,并使cpu缓存无效.达到限制后,作业将排队并仅在另一个完成时启动.

好的,现在为您的代码.我们假设我们有一个库存类型列表

List<string> types = new List<string>() { "AMEX","AMEC","BP" };

要为每个线程调度多个线程(不使用async / await),你可以做类似的事情

foreach (string t in types){    Task.Factory.StartNew(() => DoSomeCalculationForType(t));}

这将激活三个后台线程池线程并且是非阻塞的,因此这段代码几乎会立即返回给调用者.

如果要设置后期处理,可以通过continuation和continuation chaining来完成.这在我上面提供的Albahari链接中有所描述.

我希望这有帮助.

–

编辑.发表评论：

Beginning with the .NET Framework version 4,the default size of the thread pool for a process depends on several factors,such as the size of the virtual address space. A process can call the GetMaxThreads method to determine the number of threads.

但是,还有其他的东西在起作用：线程池不会立即在所有情况下创建新线程.为了应对小任务的爆发,它限制了创建新线程的速度. IIRC,如果有未完成的任务,它将每0.5秒创建一个线程,直到最大线程数.我不能立即看到这个数字,但它可能会改变.我强烈怀疑这是你所看到的.尝试排队很多项目,然后监视一段时间内的线程数.

基本上让线程池调度它想要的东西,它的优化器将为你的环境做最好的工作.

总结

以上是内存溢出为你收集整理的c# – 代码工作但似乎同步运行而不是异步全部内容，希望文章能够帮你解决c# – 代码工作但似乎同步运行而不是异步所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。