dispatch_semaphore_t信号量

2017-04-26  本文已影响0人  AntKing
 __block  long signalValue;
    //在dispatch_semaphore_wait和dispatch_semaphore_signal中的数据只能被一个线程访问
    //这在多线程同步中能够防止数据的读写错误
    //传递的参数是信号量最初值,下面例子的信号量最初值是1,这个地方如果传的是0,就会等待,如果>=1就不等待
    dispatch_semaphore_t signal = dispatch_semaphore_create(1);
    
    dispatch_time_t overTime = dispatch_time(DISPATCH_TIME_NOW, 5 * NSEC_PER_SEC);
    
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
        
        // 当信号量是0的时候,dispatch_semaphore_wait(signal, overTime);这句代码会一直等待直到overTime超时.
        //这里信号量是1 所以不会在这里发生等待.每次调用,dispatch_semaphore_wait,信号量的值就会减1,
        signalValue = dispatch_semaphore_wait(signal, overTime);//使信号量值减1
        signalValue = dispatch_semaphore_wait(signal, overTime);
        NSLog(@"first_wiat = %ld",signalValue);
        

        
        NSLog(@"需要线程同步的操作1 开始");
        NSLog(@"需要线程同步的操作1 结束");
        signalValue = dispatch_semaphore_signal(signal);//这句代码会使信号值 增加1
        //并且会唤醒一个线程去开始继续工作,如果唤醒成功,那么返回一个非零的数,如果没有唤醒,那么返回 0
        NSLog(@"first_end = %ld",signalValue);
        
    });
    
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
        
        
        signalValue =dispatch_semaphore_wait(signal, overTime);
        NSLog(@"first_wiat = %ld",signalValue);
        
        NSLog(@"需要线程同步的操作2");
        
        
        signalValue = dispatch_semaphore_signal(signal);
        
        
    });
    
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
        
        signalValue = dispatch_semaphore_wait(signal, overTime);
        NSLog(@"first_wiat = %ld",signalValue);
        NSLog(@"需要线程同步的操作3");
        
        signalValue = dispatch_semaphore_signal(signal);
        
        
    });


上一篇下一篇

猜你喜欢

热点阅读