zoukankan      html  css  js  c++  java
  • async与await线程分配研究

    using System;
    using System.Collections.Generic;
    using System.Linq;
    using System.Text;
    using System.Threading;
    using System.Threading.Tasks;
    
    namespace ATLearn
    {
        /// <summary>
        /// Guid工厂
        /// </summary>
        static class GuidFactory
        {
            //private static ThreadLocal<string> _localGuid = new ThreadLocal<string>();
            private static AsyncLocal<string> _localGuid = new AsyncLocal<string>();
            public static string CurrentGuid
            {
                get
                {
                    if (_localGuid.Value == null)
                    {
                        _localGuid.Value = Guid.NewGuid().ToString();
                    }
                    return _localGuid.Value;
                }
            }
        }
    
        class APP
        {
            private Task<int> awaitFunction(int taskId)
            {
                return Task.Factory.StartNew((obj) =>
                {
                    int itaskId = (int)obj;
                    Console.WriteLine(string.Format("taskId: {0} Await! threadId: {1} Guid: {2}", taskId, Thread.CurrentThread.ManagedThreadId, GuidFactory.CurrentGuid));
                    Thread.Sleep(2000);
                    return itaskId;
                }, (object)taskId);
            } 
    
            private async void asyncFunction(int taskId)
            {
                Console.WriteLine(string.Format("taskId: {0} Start! threadId: {1} Guid: {2}", taskId, Thread.CurrentThread.ManagedThreadId, GuidFactory.CurrentGuid));
                int num = await awaitFunction(taskId);
                Console.WriteLine(string.Format("taskId:{0} End! threadId: {1} Guid: {2}", taskId, Thread.CurrentThread.ManagedThreadId, GuidFactory.CurrentGuid));
            }
    
            public APP()
            {
                for (int i = 1; i <= 2; ++i)
                {
                    asyncFunction(i);
                }
    
    
                while (true)
                {
                    Thread.Sleep(1000);
                }
            }
        }
    
        class Program
        {
            static void Main(string[] args)
            {
                APP App = new APP();
            }
        }
    }

    可见await会开新线程

    async标志的函数为异步函数,异步函数内部,在进行await的时候会等待await后面一个线程运行结束

    而第一次await的时候,异步函数就会跳过,执行主线程里异步函数之后的内容了

  • 相关阅读:
    hdu 1025 lis 注意细节!!!【dp】
    简单的数据生成方法
    注意特殊情况!最长上升子序列!!poj2533
    括号序列问题 uva 1626 poj 1141【区间dp】
    UVa 10502【dp】
    hdu 1024 MAX Sum Plus Plus【dp】
    python 《核心编程》 1,2章
    c语言 文件链表实现最简单的学生管理系统
    Python和Python解释器
    计算机基础小结
  • 原文地址:https://www.cnblogs.com/jimaojin/p/7473136.html
Copyright © 2011-2022 走看看