zoukankan      html  css  js  c++  java
  • ios GCD信号量控制并发

    当我们在处理一系列线程的时候,当数量达到一定量,在以前我们可能会选择使用NSOperationQueue来处理并发控制,但如何在GCD中快速的控制并发呢?答案就是dispatch_semaphore,对经常做unix开发的人来讲,我所介绍的内容可能就显得非常入门级了,信号量在他们的多线程开发中再平常不过了。  信号量是一个整形值并且具有一个初始计数值,并且支持两个操作:信号通知和等待。当一个信号量被信号通知,其计数会被增加。当一个线程在一个信号量上等待时,线程会被阻塞(如果有必要的话),直至计数器大于零,然后线程会减少这个计数。  在GCD中有三个函数是semaphore的操作,分别是:  dispatch_semaphore_create   创建一个semaphore  dispatch_semaphore_signal   发送一个信号  dispatch_semaphore_wait    等待信号  简单的介绍一下这三个函数,第一个函数有一个整形的参数,我们可以理解为信号的总量,dispatch_semaphore_signal是发送一个信号,自然会让信号总量加1,dispatch_semaphore_wait等待信号,当信号总量少于0的时候就会一直等待,否则就可以正常的执行,并让信号总量-1,根据这样的原理,我们便可以快速的创建一个并发控制来同步任务和有限资源访问控制。

    dispatch_group_t group = dispatch_group_create();   
        dispatch_semaphore_t semaphore = dispatch_semaphore_create(10);   
        dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);   
        for (int i = 0; i < 100; i++)   
        {   
            dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);   
            dispatch_group_async(group, queue, ^{   
                NSLog(@"%i",i);   
                sleep(2);   
                dispatch_semaphore_signal(semaphore);   
            });   
        }   
        dispatch_group_wait(group, DISPATCH_TIME_FOREVER);   
        dispatch_release(group);   
        dispatch_release(semaphore); 
    注代码解释:创建了一个初使值为10的semaphore,每一次for循环都会创建一个新的线程,线程结束的时候会发送一个信号,线程创建之前会信号等待,所以当同时创建了10个线程之后,for循环就会阻塞,等待有线程结束之后会增加一个信号才继续执行,如此就形成了对并发的控制,如上就是一个并发数为10的一个线程队列。
    

    简单示例:

    __block BOOL isok = NO;  
          
        dispatch_semaphore_t sema = dispatch_semaphore_create(0);  
        Engine *engine = [[Engine alloc] init];  
        [engine queryCompletion:^(BOOL isOpen) {  
            isok = isOpen;  
            dispatch_semaphore_signal(sema);  
        } onError:^(int errorCode, NSString *errorMessage) {  
            isok = NO;  
            dispatch_semaphore_signal(sema);  
        }];  
          
        dispatch_semaphore_wait(sema, DISPATCH_TIME_FOREVER);  
        dispatch_release(sema); 
    
    成功的三大原则: 1、坚持 2、不要脸 3、坚持不要脸
  • 相关阅读:
    数字货币量化分析[2018-06-04]
    主流币空转多。数字货币量化分析[2018-05-31]
    草莓糖CMT依旧强势,数字货币量化分析[2018-05-29]
    数字货币量化分析[2018-05-28]
    Python3中json的encode和decode
    如何选择数字货币交易所?
    数字货币量化分析[2018-05-27]
    数字货币量化分析[2018-05-26]
    Python3中的urlencode和urldecode
    Zipline Development Guidelines
  • 原文地址:https://www.cnblogs.com/xulinmei/p/7420116.html
Copyright © 2011-2022 走看看