zoukankan      html  css  js  c++  java
  • .NET基础示例系列之三:同步异步

    SOCKET通信中的异步方法为例:

    public static ManualResetEvent ConnectDone = new ManualResetEvent(false);

     

        public static void ConnectCallback(IAsyncResult ar)

        {

            Socket sClient = (Socket)ar.AsyncState;

           

            sClient.EndConnect(ar);

           

            Console.WriteLine("Socket connected to {0}", sClient.RemoteEndPoint.ToString());

            ConnectDone.Set();

    }

     

        public static void Main(string[] arg)

        {

            try

            {

                IPHostEntry ipHost = Dns.Resolve("127.0.0.1");

                IPAddress ipAddr = ipHost.AddressList[0];

                IPEndPoint endPoint = new IPEndPoint(ipAddr, 11000);

               

                Socket sClient = new Socket(AddressFamily.InterNetwork,

                                            SocketType.Stream, ProtocolType.Tcp);

               

                sClient.BeginConnect(endPoint, new AsyncCallback(ConnectCallback),

                                     sClient);

               

                for (int i = 0; i <5; i++)

                    Console.WriteLine("Do Some Other Work.");

                

                byte[] byteData = Encoding.ASCII.GetBytes("Some Data.");

                

    ConnectDone.WaitOne();

               

                sClient.BeginSend(byteData, 0, byteData.Length, 0,

                                  new AsyncCallback(SendCallback), sClient);

               

                ………

        }

     

    (注:ManualResetEvent 允许线程通过发信号互相通信。通常,此通信涉及一个线程在其他线程进行之前必须完成的任务。

    ManualResetEvent就像一个信号灯,可以利用它的信号来通知其它线程。它有几个重要的方法:Reset()Set()WaitOne()。初始化该对象时,用户可以指定其默认的状态(有信号/无信号),在初始化以后,该对象将保持原来的状态不变直到它的Reset()或者Set()方法被调用,Reset()方法将其设置为无信号状态,Set()方法将其设置为有信号状态。WaitOne()方法使当前线程挂起直到ManualResetEvent对象处于有信号状态,此时该线程将被激活。)

     

    本例中,主线程调用ConnectDone.WaitOne();后,主线程阻塞,直到连接操作(即ConnectCallback)完成,因为连接操作完成之后,执行了ConnectDone.Set()将信号灯设置为有信号,由于调用了ManualResetEvent.WaitOne()方法而处在等待状态的主线程将接收到这个信号,于是它接着往下执行,完成后边的工作。

     

    同步与异步:

    简单地说,同步即程序执行一个方法,等该方法返回之后,继续往下走,

    异步:即程序调用一个方法后立即返回,“宏观”而言,主线程与方法线程并行执行。

    就本例而言,socket的异步方法BeginConnect被调用后,接着执行主线程中该语句之后的代码,即:

    for (int i = 0; i <5; i++)

    Console.WriteLine("Do Some Other Work.");

    byte[] byteData = Encoding.ASCII.GetBytes("Some Data.");

    如果调用的是同步方法,那么,输出“Socket connected to”一定会在“Do Some Other Work.”之前,因为主线程必须等待同步方法的返回,但是在异步的情况下,将可能在5行“Do Some Other Work.”之间的某个时刻出现“Socket connected to”的输出(实际情况还依赖于操作系统的线程调度)。

    至于在sClient.BeginSend()方法之前调用ConnectDone.WaitOne(),则是由于前者依赖于连接操作(即ConnectCallback)的完成,须得同步一下。

  • 相关阅读:
    THUSC & 中考 & NOI 拉跨记
    Spring Security中的密码安全
    Spring Security 中的 CSRF和CORS
    Jacoco代码覆盖率
    Kafka拦截器
    shell遍历多个数组
    shell中的函数
    SpringSecurity权限控制
    SpringSecurity的@EnableWebSecurity注解
    SpringBoot配置自定义包扫描
  • 原文地址:https://www.cnblogs.com/morvenhuang/p/475710.html
Copyright © 2011-2022 走看看