|
一、简介: dispatch_semaphore_t:表示信号,生成信号的方法是 dispatch_semaphore_t semaphore= dispatch_semaphore_create(); dispatch_semaphore_wait:信号等待,它像一个安保,比如小区规定最多只能进入3辆车,而进入一辆车后名额就会减少一个,当剩下的名额为0的时候,再有汽车说要进去时,就只能在外面等待了,直到有名额闲置出来了,才能开进小区。 dispatch_semaphore_signal:信号释放,当有一辆车从小区出来时,就腾出来了一个名额。
二、代码示例: /** 标识信号量 */ @property (nonatomic ,assign) int state; dispatch_group_t group = dispatch_group_create(); dispatch_queue_t queue = dispatch_get_global_queue(0, 0); dispatch_group_async(group, queue, ^{ // 循环上传数据 for (int j=0; j<3; j++) { state = j; // 创建dispatch_semaphore_t对象 dispatch_semaphore_t semaphore = dispatch_semaphore_create(0); // 进行网络请求等操作 if(success) { // 请求成功发送信号量(+1) dispatch_semaphore_signal(semaphore); }else { // 失败也请求成功发送信号量(+1) dispatch_semaphore_signal(semaphore); } // 信号量减1,如果>0,则向下执行,否则等待 dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER); } }); // 当所有队列执行完成之后 dispatch_group_notify(group,dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{ if (state == 3) { // 返回主线程进行界面上的修改 dispatch_async(dispatch_get_main_queue(), ^{ }); }else { dispatch_async(dispatch_get_main_queue(), ^{ }); } });
|