zoukankan      html  css  js  c++  java
  • Socket异步发送的同步控制

    在网络通信中,我们使用Socket异步发送数据,但在客户端,往往是需要等待服务器的返回结果后(握手过程)再往下执行,这就涉及到同步控制了,在多次的实现中,使用AutoResetEvent,实现不,即有时候发现,Socket数据返回比阻塞的UI线程快,不知道是Socket的优先级别高,还是什么原因。总之,这个同步控制是失败的。后来经研究,想到了解决办法,只要发送线程和接收线程同时对ThreadSemaphore进行操作,发送数据时调用Wait方法,收到Socket返回的数据时调用Set方法,问题解决。对于信号量的同步控制有很多场合的应该,不同的场合可以设计不同的实现。看了很多的实现,都是需求相对复杂的,而我的需求就是阻塞UI线程,等待服务器返回结果后再往下执行,所以只能参考别的实现,自己设计(下面程序没有经过测试,只是一个即时设计)。

    public class ThreadSemaphore

    {

      bool m_isSocketReturn;

      public bool Wait(int timeout)

      {

        lock(this)

        {

          if (!m_isSocketReturn && !Monitor.Wait(this, timeout)

             retun m_isSocketReturn;

        }

        retun m_isSocketReturn;

      }

      pulic void Set()

      {

        lock(this)

        {

          m_isSocketReturn = true;

          Monitor.PulseAll(this);

        }

      }

    }

  • 相关阅读:
    c/c++ 数组的智能指针 使用
    c/c++ 智能指针 weak_ptr 使用
    在ubuntu18.04上安装EOS
    c/c++ 智能指针 unique_ptr 使用
    python基础-内置装饰器classmethod和staticmethod
    java中5种异步转同步方法
    java自定义注解
    多线程之线程池(Thread,Runnable,callable,Future,FutureTask)
    java反射
    重写ThreadFactory方法和拒绝策略
  • 原文地址:https://www.cnblogs.com/Yjianyong/p/3618844.html
Copyright © 2011-2022 走看看