GCD之信号量机制二

在前面GCD之信号量机制一中介绍了通过信号量设置并行最大线程数,依此信号量还可以防止多线程访问公有变量时数据有误,下面的代码能说明。

1.下面是不采用信号量修改公有变量的值

 dispatch_group_t group=dispatch_group_create();
//    dispatch_semaphore_t semaphore=dispatch_semaphore_create(1);
    dispatch_queue_t queue=dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    __block int count=1000;
    for (int i=0; i<100; i++) {
        //信号量减1,如果同时开启10个以上的线程,则信号量小于等于0,此时就会阻塞该线程。
//        dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
        dispatch_group_async(group, queue, ^{
            int value = (arc4random() % 4) + 6;
            NSLog(@"%d-%d= %d",count,value,count-value);
            count=count-value;
        //每个线程执行减1后通过信号量通知加1,这样始终保持线程在10个之内
//        dispatch_semaphore_signal(semaphore);
        });
    }

    dispatch_group_wait(group, DISPATCH_TIME_FOREVER);

2.运行结果如下:

3.声明一个初始值为1的信号量来开启线程修改公有变量时

 dispatch_group_t group=dispatch_group_create();
    dispatch_semaphore_t semaphore=dispatch_semaphore_create(1);
    dispatch_queue_t queue=dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    __block int count=1000;
    for (int i=0; i<100; i++) {
        //信号量减1,如果同时开启10个以上的线程,则信号量小于等于0,此时就会阻塞该线程。
        dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
        dispatch_group_async(group, queue, ^{
            int value = (arc4random() % 4) + 6;
            NSLog(@"%d-%d= %d",count,value,count-value);
            count=count-value;
        //每个线程执行减1后通过信号量通知加1,这样始终保持线程在10个之内
        dispatch_semaphore_signal(semaphore);
        });
    }

    dispatch_group_wait(group, DISPATCH_TIME_FOREVER);

4.运行结果如下:

可以看到,第一代码段时修改公有变量时不是有序的,第二个代码段才是真正正确的修改顺序。这过程可取款的过程一样,金额是1000,可能在不同的地方同时取款,取款时不可能金额是像第一代码段那样。这个和C#的lock关键字有一样的效果。

时间: 2024-08-01 12:49:36

GCD之信号量机制二的相关文章

GCD之信号量机制一

在使用NSOperationQueue进行多线程编程时,可通过[queue setMaxConcurrentOperationCount:5]来设置线程池中最多并行的线程数,在GCD中信号量机制也和它相似,可以控制并发的线程数量. 1.首先熟悉下几个函数 dispatch_semaphore_create 创建一个信号量,设置一个初始值dispatch_semaphore_signal 发送一个信号,信号通知,信号量+1dispatch_semaphore_wait 等待信号,信号量-1 当一个

操作系统——信号量机制

一.知识总览 信号量机制的基本原理:两个或多个进程可以利用彼此间收发的简单的信号来实现“正确的”并发执行,一个进程在收到一个指定信号前,会被迫在一个确定的或者需要的地方停下来,从而保持同步或互斥. 二.整型信号量 三.记录型信号量 typedef struct{ int value; struct process *L; }semaphore//信号量 void wait(semaphore S){//wait原语 S.value--; if(S.value<0){ block(S.L);//阻

android binder 机制二(client和普通server)

在讲它们之间的通信之前,我们先以MediaServer为例看看普通Server进程都在干些什么. int main() { -- // 获得ProcessState实例 sp<ProcessState> proc(ProcessState::self()); // 得到ServiceManager的Binder客户端实例 sp<IServiceManager> sm = defaultServiceManager(); -- // 通过ServiceManager的Binder客户

Solr4.8.0源码分析(19)之缓存机制(二)

Solr4.8.0源码分析(19)之缓存机制(二) 前文<Solr4.8.0源码分析(18)之缓存机制(一)>介绍了Solr缓存的生命周期,重点介绍了Solr缓存的warn过程.本节将更深入的来介绍下Solr的四种缓存类型,以及两种SolrCache接口实现类. 1.SolrCache接口实现类 前文已经提到SolrCache有两种接口实现类:solr.search.LRUCache 和 solr.search.LRUCache. 那么两者具体有啥区别呢? 1.1 solr.search.LR

iOS事件机制(二)

iOS事件机制(二) DEC 29TH, 2013 本篇内容接上一篇iOS事件机制(一),本次主要介绍iOS事件中的多点触控事件和手势事件. 从上一篇的内容我们知道,在iOS中一个事件用一个UIEvent对象表示,UITouch用来表示一次对屏幕的操作动作,由多个UITouch对象构成了一个UIEvent对象.另外,UIResponder是所有响应者的父类,UIView.UIViewController.UIWindow.UIApplication都直接或间接的集成了UIResponder.关于

【操作系统总结】进程同步的信号量机制

信号量机制是由dijkstra 1965年提出,是解决进程同步重要的工具 下面方法适用与几个进程访问同一个临界区 整形信号量 定义一个表示资源数目的整形信号量S,仅能同步P, V操作改变.原始值S=1,每一个进程来的时候会执行: 首先执行wait()操作,如果信号量s<=0就会一直检测并阻塞 如果不小于0就会进入临界区,并把S设为0,保证其他进程无法进去临界区 在临界区执行完,再把信号量设置回来. wait(S) { while(S <= 0);//资源如果小余0就会阻塞.一直在这边检测 S-

信号量机制

11.1 2 个程序的例子 先看 2 个程序: #include<unistd.h> int main(void) { allarm(10); for(;;;); } 这段程序的含义比较明显:这个程序在一个无限循环中,直到过了 10 秒,之后 程序被终止. 在来看另外一个程序: Static void setvalue(void) { Flag=1; } int main(void) { int sum=0; int flag=0; struct sigaction act; act.sa_h

操作系统之信号量机制总结

1965年,荷兰学者Djikstra提出信号量(Semaphores)机制是一种卓有成效的进程同步工具.在长期的应用中,信号量机制又获得了很大的发展,从整型信号量记录型信号量,进而发展成"信号量集"机制,下面我们来讨论一下各种信号量机制的内容. 1.整形信号量(经典的PV操作:P(wait):申请资源 V(signal):释放资源) 1 wait(S):while S<=0 do no-op; 2 S:=S-1; 3 signal(S): S:=S+1 2.记录型信号量 在整形信

锁机制,信号量机制,事件机制

IPC -- inter process Communication  进程间通信 守护进程随着父进程的代码执行完毕才结束 代码:from multiprocessing import Processimport time def func1(): for i in range(65,90): print(chr(i)) time.sleep(0.5) def func(): for i in range(10): print(i) time.sleep(0.5) if __name__ ==