线程

GCD总结

2018-03-06  本文已影响11人  CowboyBebop

一,基本

//是否多线程
  [NSThread isMultiThreaded];
//串行队列
 dispatch_queue_t serialQueue1 = dispatch_queue_create("queue1", DISPATCH_QUEUE_SERIAL);
 //并行队列
 dispatch_queue_t concurrentQueue2 = dispatch_queue_create("queue2", DISPATCH_QUEUE_CONCURRENT);
 //主队列
 dispatch_queue_t mainQueue = dispatch_get_main_queue();
 //全局队列
 dispatch_queue_t globalQueue1 = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_HIGH, 0);
 
 dispatch_queue_t globalQueue2 = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);

 //dispatch_after 
 dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(1 * NSEC_PER_SEC)), 
             dispatch_get_main_queue(), ^{
             //do something
 });
//单例 dispatch_once
static dispatch_once_t onceToken;
dispatch_once(&onceToken, ^{
        <#code to be executed once#>
});
dispatch_queue_t q = dispatch_queue_create("fs", DISPATCH_QUEUE_SERIAL);
NSLog(@"start--%@",[NSThread currentThread]);
for (int i=0; i<10; i++) {
        dispatch_async(q, ^{
            NSLog(@"async--%@",[NSThread currentThread]);
        });
}
NSLog(@"end--%@",[NSThread currentThread]);

串行队列 异步任务,会创建子线程,且只创建一个子线程,异步任务执行是有序的。

 dispatch_queue_t q = dispatch_queue_create("fs", DISPATCH_QUEUE_SERIAL);
    NSLog(@"start--%@",[NSThread currentThread]);
    for (int i=0; i<10; i++) {
        dispatch_sync(q, ^{
            NSLog(@"sync--%@---%d",[NSThread currentThread],i);
        });
    }
    NSLog(@"end--%@",[NSThread currentThread]);

串行队列 同步任务,不创建新线程,同步任务执行是有序的。

dispatch_queue_t q = dispatch_queue_create("fs", DISPATCH_QUEUE_CONCURRENT);
 NSLog(@"start--%@",[NSThread currentThread]);
 for (int i=0; i<10; i++) {
        dispatch_async(q, ^{
            NSLog(@"async--%@---%d",[NSThread currentThread],i);
        });
}
NSLog(@"end--%@",[NSThread currentThread]);

并行队列 异步任务 创建子线程,且多个子线程,异步任务打印结果无序。

dispatch_queue_t q = dispatch_queue_create("fs", DISPATCH_QUEUE_CONCURRENT);
    NSLog(@"start--%@",[NSThread currentThread]);
    for (int i=0; i<10; i++) {
        dispatch_sync(q, ^{
            NSLog(@"sync--%@---%d",[NSThread currentThread],i);
        });
    }
    NSLog(@"end--%@",[NSThread currentThread]);

并行队列 同步任务,不创建新线程,同步任务执行是有序的。

总结上面的四种情况得出结论:
(1)同步、异步决定是否创建子线程,同步任务不创建子线程,都是在主线程中执行,异步任务创建子线程。
(2)串行、并行决定创建子线程的个数,串行创建一个子线程,并行创建多个子线程(具体几个由系统决定)。

串行队列同步执行,既在当前线程中顺序执行
串行队列异步执行,开辟一条新的线程,在该线程中顺序执行
并行队列同步执行,不开辟线程,在当前线程中顺序执行
并行队列异步执行,开辟多个新的线程,并且线程会重用,无序执行
主队列异步执行,不开辟新的线程,顺序执行
主队列同步执行,会造成死锁('主线程'和'主队列'相互等待,卡住主线程)

二,线程组 dispatch_group_t

 dispatch_queue_t queue1 = dispatch_queue_create("queue2", DISPATCH_QUEUE_CONCURRENT);
 
 dispatch_group_t group = dispatch_group_create();
 
 dispatch_group_async(group, queue1, ^{
 
 NSLog(@"1111");
 });
 
 dispatch_group_async(group, queue1, ^{
 
 NSLog(@"2222");
 });
 dispatch_group_async(group, queue1, ^{
 
 NSLog(@"3333");
 });
 //写法一
 //    dispatch_group_notify(group, queue1, ^{
 //        NSLog(@"4444");
 //    });
 //写法二
 dispatch_group_wait(group, DISPATCH_TIME_FOREVER);
 NSLog(@"4444");
//    dispatch_group_enter,dispatch_group_leave,必须是成对出现的
    dispatch_group_t group = dispatch_group_create();

    dispatch_queue_t queue = dispatch_queue_create("queue2", DISPATCH_QUEUE_CONCURRENT);
    
    //  dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    
    dispatch_group_enter(group);
    
    dispatch_async(queue, ^{
        [NSThread sleepForTimeInterval:3];
        NSLog(@"1111");
        //请求完成之后离开
        dispatch_group_leave(group);
    });
    dispatch_group_enter(group);
    dispatch_async(queue, ^{
        [NSThread sleepForTimeInterval:1];
        NSLog(@"2222");
        //请求完成之后离开
        dispatch_group_leave(group);
    });
    
    dispatch_group_notify(group, dispatch_get_main_queue(), ^{
        NSLog(@"所有的网络请求都执行结束了");
    });

三,栅栏函数 dispatch_barrier_async

dispatch_queue_t concurrentQueue = dispatch_queue_create("queue", DISPATCH_QUEUE_CONCURRENT);
 
 dispatch_async(concurrentQueue, ^{
 NSLog(@"1");
 });
 
 dispatch_async(concurrentQueue, ^{
 NSLog(@"2");
 });
 
 dispatch_barrier_async(concurrentQueue, ^{
 NSLog(@"barrier");
 });
 
 dispatch_async(concurrentQueue, ^{
 NSLog(@"3");
 });
 
 dispatch_async(concurrentQueue, ^{
 NSLog(@"4");
 });

dispatch_barrier_sync 和 dispatch_barrier_async
共同点:
1、等待在它前面插入队列的任务先执行完
2、等待他们自己的任务执行完再执行后面的任务
不同点:
1、dispatch_barrier_sync将自己的任务插入到队列的时候,需要等待自己的任务结束之后才会继续插入被写在它后面的任务,然后执行它们
2、dispatch_barrier_async将自己的任务插入到队列之后,不会等待自己的任务结束,它会继续把后面的任务插入到队列,然后等待自己的任务结束后才执行后面任务。

四,dispatch_queue_set_specific 和 dispatch_get_specific

详细内容可以看这两篇文章:

http://blog.csdn.net/xiaoluodecai/article/details/47212585
http://www.cocoachina.com/ios/20160802/17259.html
判断主线程的方法

 [NSThread isMainThread];

判断主队列的方法,可以给目标队列绑定一个key,然后根绝 dispatch_get_specific 取出目标队列来判断当前队列和目标队列是否同一个队列。

- (BOOL) isMainQueue{
    static const void * mainQueueKey = @"mainQueueKey";
    static void * mainQueueContext = @"mainQueueContext";
    static dispatch_once_t onceToken;
    dispatch_once(&onceToken, ^{
        dispatch_queue_set_specific(dispatch_get_main_queue(), mainQueueKey, mainQueueContext, NULL);
    });
    return dispatch_get_specific(mainQueueKey) == mainQueueContext;
}

五,信号量 dispatch_semaphore_t

dispatch_group_t group = dispatch_group_create();
dispatch_semaphore_t semaphore = dispatch_semaphore_create(10);
dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
for (int i = 0; i < 100; i++)
{
        dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);
        dispatch_group_async(group, queue, ^{
            NSLog(@"%i,%d",i,[NSThread isMainThread]);
            
            sleep(2);
            dispatch_semaphore_signal(semaphore);
        });
    }
dispatch_group_wait(group, DISPATCH_TIME_FOREVER);

创建了一个初使值为10的semaphore,每一次for循环都会创建一个新的线程,线程结束的时候会发送一个信号,线程创建之前会信号等待,所以当同时创建了10个线程之后,for循环就会阻塞,等待有线程结束之后会增加一个信号才继续执行,如此就形成了对并发的控制,如上就是一个并发数为10的一个线程队列。

上一篇 下一篇

猜你喜欢

热点阅读