美文网首页
DispatchSemaphore

DispatchSemaphore

作者: emore | 来源:发表于2019-10-08 12:14 被阅读0次

    /// 信号量对象
    class DispatchSemaphore {

    /// 创建一个信号量, 并设置初始值
    /// - Parameters:
    ///   - value: 信号量的初始值。必须>=0,否则会返回NULL。
    /// - Returns: 信号量对象
    init(value: Int) 
    
    /// 发送信号量。该函数会对信号量的值进行+1操作。
    /// - Returns:
    ///   - 当返回值=0时,表示当前不存在线程因为wait而阻塞。
    ///   - 当返回值>0时,表示其当前有(一个或多个)线程因为wait而阻塞,并且唤醒一个等待的线程(当线程有优先级时,唤醒优先级最高的线程;否则随机唤醒)。
    func signal() -> Int 
    
    /// 等待信号量。该函数会对信号量的值进行-1操作。这个函数的作用是这样:
    ///   如果信号量的值>0,该函数所处线程就继续执行下面的语句,并且将信号量的值-1;
    ///   如果信号量的值=0,那么这个函数就阻塞当前线程等待timeout,
    ///     如果等待期间信号量的值被signal函数+1了,且该函数(即dispatch_semaphore_wait)所处线程获得了信号量,那么就继续向下执行并将信号量-1。
    ///     如果等待期间没有获取到信号量或者信号量的值一直为0,那么等到timeout时,其所处线程自动执行其后语句。
    func wait() 
    
    /// 等待信号量。可以设置等待超时时间
    /// - Parameters:
    ///   - timeout: DispatchTime为主板时间CPU时钟计时
    /// - Returns:
    ///   - 当返回值=DispatchTimeoutResult.success时,表示在timeout之前,该函数所处的线程被成功唤醒。
    ///   - 当返回值=DispatchTimeoutResult.timedOut时,表示timeout发生。
    func wait(timeout: DispatchTime) -> DispatchTimeoutResult 
    
    /// 等待信号量。可以设置等待超时时间
    /// - Parameters:
    ///   - timeout: DispatchWallTime为实际时间即系统时间
    /// - Returns:
    ///   - 当返回值=DispatchTimeoutResult.success时,表示在timeout之前,该函数所处的线程被成功唤醒。
    ///   - 当返回值=DispatchTimeoutResult.timedOut时,表示timeout发生。
    func wait(wallTimeout: DispatchWallTime) -> DispatchTimeoutResult 
    

    }
    参考: https://blog.csdn.net/huayu608/article/details/90407175

    例一:


    image.png

    此处semaphore初始值为0,执行wait后阻塞主线程,导致主线程的回调无法执行,所以只打印了1

    例二:


    image.png

    semaphore初始值0,执行wait后阻塞主线程,global线程执行后调用signal发送信号量,信号量+1,wait处收到通知继续执行

    例三:使用信号量控制并发任务最大数量 参考:https://juejin.im/post/5c761d36f265da2d84109277

    image.png

    相关文章

      网友评论

          本文标题:DispatchSemaphore

          本文链接:https://www.haomeiwen.com/subject/oicuuctx.html