今天还是大年初四,吃吃喝喝睡睡玩玩,都没有心情去敲代码。每年都要欺骗自己一次,过年放假都要计划学XXX,计划次次泡汤,人就是喜欢这么自欺欺人。
明明什么都知道,吃个醋都名不正言不顺,多少次用这是最后一次来说服自己,却依旧干着同样的事。进一步没资格,退一步舍不得,虽然在抖音上看到的,但是真的很有道理。25了,还是这么盲目,有时候真的很想给自己找个台阶下去。
感觉今年收货还是有的,昨天刚把这期的贷款还完,不知不觉已经缴满12期,一年了。以前没有房贷的时候,也是存不下钱来,买电脑、相机、私教,总之有多少花多少,一点规划都没有。刚开始前几个月的时候,压得有点喘不过气来,这不能花,那不能买,所有的压力都自己扛。后来慢慢习惯了,还能存下钱来,虽然不多,但是养成了强制储蓄的习惯。贷款账单上的数字一点点的减少,每个月多出来的一点点软妹币,体重秤上的数字一点点的下降,看着实实在在的改变,这些才是单身狗要的安全感(又是自我安慰~)。
接着上篇的GCD的使用(一)来讲
五 任务组dispatch_group
在图片上传的时候,用的比较多。就是放队列中所有的任务都执行完毕后去做一些操作。
分为两种方式,先介绍第一种dispatch_group_async()函数,这个函数会将队列和任务相关联,自动执行。
NSLog(@"任务组自动管理");
dispatch_queue_t concurrentQueue = [self getConcurrentQueue:"group"];
dispatch_group_t group = dispatch_group_create();
for (int i = 0 ; i < 3 ; i ++ )
{
//将group与queue进行管理,并且自动执行
dispatch_group_async(group, concurrentQueue, ^{
[self currentThreadSleep:1];
NSLog(@"任务%d执行完毕",i);
});
}
dispatch_group_notify(group, [self getMainQueue], ^{
[self currentThreadSleep:2];
NSLog(@"所有任务都执行完毕");
});
NSLog(@"异步执行测试,不会阻塞当前线程");
从上面的结果可以看出,队列中任务以及通知结果的处理都是异步处理的,不会阻塞当前线程,当队列中所有的任务完成后,就会在主线程执行dispatch_group_notify()中的闭包。
下面介绍第二种方式,手动管理任务组与队列的关系。使用dispatch_group_enter()来进入任务组,使用dispatch_group_leave()来离开任务组。dispatch_group_wait就是阻塞当前线程,等待任务组的任务完成。等待时间设置为DISPATCH_TIME_FOREVER,永不超时,直到任务组结束。
NSLog(@"任务组手动管理");
dispatch_queue_t concurrentQueue = [self getConcurrentQueue:"group"];
dispatch_group_t group = dispatch_group_create();
for (int i = 0 ; i < 3 ; i ++ )
{
//进入队列组
dispatch_group_enter(group);
dispatch_async(concurrentQueue, ^{
[self currentThreadSleep:1];
NSLog(@"任务%d执行完毕",i);
//离开队列组
dispatch_group_leave(group);
});
}
//阻塞当前线程,直到所有任务执行完毕
dispatch_group_wait(group, DISPATCH_TIME_FOREVER);
NSLog(@"所有任务执行完毕");
dispatch_group_notify(group, concurrentQueue, ^{
[self currentThreadSleep:3];
NSLog(@"手动管理队列执行完毕");
});
六 信号量同步锁
有时候多个线程对同一个数据进行操作的时候,为了数据的一致性,只允许一次只有一个线程来操作这个数据。dispatch_semaphore_t是信号量。信号量为0就是上锁的状态,其他线程使用数据就要等待,不为0就是开锁状态,可以使用数据。使用dispatch_semaphore_create()来创建信号量,dispatch_semaphore_wait()来上锁,第一个参数是操作的信号量,第二个参数是等待时间,DISPATCH_TIME_FOREVER一直等下去。完成操作后,通过dispatch_semaphore_signal()来将信号量+1,达到解锁的目的。
dispatch_queue_t concurrentQueue = [self getSerialQueue:"semaphore"];
//创建信号量
dispatch_semaphore_t semaphoreLock = dispatch_semaphore_create(1);
__block int testNumber = 0 ;
for (int i = 0 ; i < 3 ; i ++ )
{
dispatch_async(concurrentQueue, ^{
//上锁
dispatch_semaphore_wait(semaphoreLock, DISPATCH_TIME_FOREVER);
testNumber += 1;
[self currentThreadSleep:1];
NSLog(@"%@",[self getCurrentThread]);
NSLog(@"第%d次执行:testNumber = %d",i , testNumber);
//开锁
dispatch_semaphore_signal(semaphoreLock);
});
}
NSLog(@"异步执行测试");
下次再把剩余的内容给梳理清楚。