GCD的基础用法

2017-04-12  本文已影响26人  杨帅iOS

- (void)viewDidLoad {

[super viewDidLoad];

//    [self async_concurrent_queue];

//    [self async_serial_queue];//异步串行创建一个新的线程 但是只在一个线程中执行

//    [self sync_concurrent_queue];//同步执行不创建新线程

//    [self sync_serial_queue];//同步执行不创建新线程

//    [self setTargetQueue];//赋予队列优先级

//    [self queueAfter];//延时加载

//    [self dispatchGroup];//分组管理任务,能监测整个分组中的任务执行状态

//    [self dispatch_apply];//指定次数将block添加到指定queue中

//    [self suspend_resume];//暂停和开始线程

[self test];

}

//异步并行线程

- (void)async_concurrent_queue{

dispatch_queue_t queue = dispatch_queue_create("queue", DISPATCH_QUEUE_CONCURRENT);

dispatch_async(queue, ^{

NSLog(@"1");

NSLog(@"%@",[NSThread currentThread]);

});

dispatch_async(queue, ^{

NSLog(@"2");

NSLog(@"%@",[NSThread currentThread]);

});

dispatch_async(queue, ^{

NSLog(@"3");

NSLog(@"%@",[NSThread currentThread]);

});

dispatch_async(queue, ^{

NSLog(@"4");

NSLog(@"%@",[NSThread currentThread]);

});

dispatch_async(queue, ^{

NSLog(@"5");

NSLog(@"%@",[NSThread currentThread]);

});

}

//异步串行线程

- (void)async_serial_queue{

dispatch_queue_t queue = dispatch_queue_create("queue", DISPATCH_QUEUE_SERIAL);

dispatch_async(queue, ^{

NSLog(@"1");

NSLog(@"%@",[NSThread currentThread]);

});

dispatch_async(queue, ^{

NSLog(@"2");

NSLog(@"%@",[NSThread currentThread]);

});

dispatch_async(queue, ^{

NSLog(@"3");

NSLog(@"%@",[NSThread currentThread]);

});

dispatch_async(queue, ^{

NSLog(@"4");

NSLog(@"%@",[NSThread currentThread]);

});

dispatch_async(queue, ^{

NSLog(@"5");

NSLog(@"%@",[NSThread currentThread]);

});

}

//同步并行

- (void)sync_concurrent_queue{

dispatch_queue_t queue = dispatch_queue_create("queue", DISPATCH_QUEUE_SERIAL);

dispatch_sync(queue, ^{

NSLog(@"1");

NSLog(@"%@",[NSThread currentThread]);

});

dispatch_sync(queue, ^{

NSLog(@"2");

});

dispatch_sync(queue, ^{

NSLog(@"3");

});

dispatch_sync(queue, ^{

NSLog(@"4");

});

dispatch_sync(queue, ^{

NSLog(@"5");

NSLog(@"%@",[NSThread currentThread]);

});

}

//同步串行

- (void)sync_serial_queue{

dispatch_queue_t queue = dispatch_queue_create("queue", DISPATCH_QUEUE_SERIAL);

dispatch_sync(queue, ^{

NSLog(@"1");

NSLog(@"%@",[NSThread currentThread]);

});

dispatch_sync(queue, ^{

NSLog(@"2");

});

dispatch_sync(queue, ^{

NSLog(@"3");

});

dispatch_sync(queue, ^{

NSLog(@"4");

});

dispatch_sync(queue, ^{

NSLog(@"5");

NSLog(@"%@",[NSThread currentThread]);

});

}

//设置队列优先级

- (void)setTargetQueue{

//创建一个队列

dispatch_queue_t myqueue = dispatch_queue_create("com.example.myqueue", DISPATCH_QUEUE_CONCURRENT);

//创建目标队列

dispatch_queue_t targetQueue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_BACKGROUND, 0);

//myqueue 使用 targetQueue的优先级策略

dispatch_set_target_queue(myqueue, targetQueue);

}

//延时处理

- (void)queueAfter{

//设置定时器时间

dispatch_time_t time = dispatch_time(DISPATCH_TIME_NOW,  3ull * NSEC_PER_SEC);

dispatch_after(time, dispatch_get_main_queue(), ^{

NSLog(@"延时3秒调用");

});

}

//分组管理任务,能够整个分组中的执行结果

- (void)dispatchGroup{

dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);

dispatch_group_t group = dispatch_group_create();

dispatch_group_async(group, queue, ^{

NSLog(@"1");

});

dispatch_group_async(group, queue, ^{

NSLog(@"2");

});

dispatch_group_async(group, queue, ^{

NSLog(@"3");

});

dispatch_group_notify(group, queue, ^{//完成线程中的人物 通知得到响应

dispatch_time_t time = dispatch_time(DISPATCH_TIME_NOW, 3ull * NSEC_PER_SEC);

dispatch_after(time, dispatch_get_main_queue(), ^{

NSLog(@"完成任务啦");

});

});

}

//该函数按指定的次数将指定的Block追加到指定的Dispatch Queue中,并等到全部的处理执行结束 //跟for循环类似

- (void)dispatch_apply{

dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT,0);

dispatch_apply(10, queue, ^(size_t index) {

NSLog(@"%zu", index);

});

}

//暂停queue 开始queue

- (void)suspend_resume{

dispatch_queue_t queue = dispatch_queue_create("com.test.gcd", DISPATCH_QUEUE_SERIAL);

//提交第一个block,延时5秒打印。

dispatch_async(queue, ^{

sleep(5);

NSLog(@"After 5 seconds...");

});

//提交第二个block,也是延时5秒打印

dispatch_async(queue, ^{

sleep(5);

NSLog(@"After 5 seconds again...");

});

//延时一秒

NSLog(@"sleep 1 second...");

sleep(1);

//挂起队列

NSLog(@"suspend...");

dispatch_suspend(queue);

//延时10秒

NSLog(@"sleep 10 second...");

sleep(10);

//恢复队列

NSLog(@"resume...");

dispatch_resume(queue);

//    dispatch_suspend并不会立即暂停正在运行的block,而是在当前block执行完成后,暂停后续的block执行。

}

//单例模式

+ (instancetype)sharedManager{

static dispatch_once_t onceToken;

static ViewController * vc = nil;

dispatch_once(&onceToken, ^{

vc = [[ViewController alloc]init];

});

return vc;

}

#pragma mark --------------死锁

//!!!只有使用了dispatch_sync函数分发任务到 当前队列 才会导致死锁。

//对于dispatch_sync同步等待执行函数要谨慎使用。

//在主线程队列调用dispatch_sync 就会造成死锁

//calling this function and targeting the current queue resuls in deadlock

- (void)test{

dispatch_queue_t mainQueue = dispatch_get_main_queue();

dispatch_sync(mainQueue, ^{

/*

主线程停在同步提交任务这一步,导致block不会执行,

block不执行,同步提交任务就会停留在主线程中一直等待,导致死锁

当前队列是主队列,block被提交到了当前队列

*/

NSLog(@"Hello?");

});

//    当前队列是主队列,使用dispatch_sync函数,block被提交到了当前队列

dispatch_async(mainQueue, ^{

dispatch_sync(mainQueue, ^{

/*

同样由于主队列任务互相等待造成死锁

*/

});

});

}

上一篇下一篇

猜你喜欢

热点阅读