多线程

  • GCD
#pragma mark - GCD队列的组合
//1.并发队列 + 同步执行:没有开启新线程,串行执行任务
- (void)syncConcurrent {
    NSLog(@"---------syncConcurrent----start");
    
    dispatch_queue_t concurrentQueue = dispatch_queue_create("concurrentQueue", DISPATCH_QUEUE_CONCURRENT);
    dispatch_sync(concurrentQueue, ^{
        for (int i = 0; i < 5; i++) {
            NSLog(@"1:%d---%@", i, [NSThread currentThread]);
        }
    });
    
    dispatch_sync(concurrentQueue, ^{
        for (int i = 0; i < 5; i++) {
            NSLog(@"2:%d---%@", i, [NSThread currentThread]);
        }
    });
    
    dispatch_sync(concurrentQueue, ^{
        for (int i = 0; i < 5; i++) {
            NSLog(@"3:%d---%@", i, [NSThread currentThread]);
        }
    });
    
    NSLog(@"---------syncConcurrent----end");
    
}
//2.并发队列 + 异步执行:开启新线程,并发执行任务 (除了主线程,又开启了3个线程,并且任务是交替着同时执行的,任务不是马上执行,而是将所有任务添加到队列之后才开始同步执行)
- (void)asyncConcurrent {
    NSLog(@"---------asyncConcurrent----start");
    
    dispatch_queue_t concurrentQueue = dispatch_queue_create("concurrentQueue", DISPATCH_QUEUE_CONCURRENT);
    
    dispatch_async(concurrentQueue, ^{
        for (int i = 0; i < 5; i++) {
            NSLog(@"1:%d---%@", i, [NSThread currentThread]);
        }
    });
    
    dispatch_async(concurrentQueue, ^{
        for (int i = 0; i < 5; i++) {
            NSLog(@"2:%d---%@", i, [NSThread currentThread]);
        }
    });
    
    dispatch_async(concurrentQueue, ^{
        for (int i = 0; i < 5; i++) {
            NSLog(@"3:%d---%@", i, [NSThread currentThread]);
        }
    });
    
    
    NSLog(@"---------asyncConcurrent----end");
    
}

//3.串行队列 + 同步执行:没有开启新线程,串行执行任务(所有任务都是在主线程中执行的,并没有开启新的线程。而且由于串行队列,所以按顺序一个一个执行。加入以后,立即执行)
- (void)syncSerial {
    NSLog(@"------sycnSerial__start-----");
    dispatch_queue_t serialQueue = dispatch_queue_create("serialQueue", DISPATCH_QUEUE_SERIAL);
    
    dispatch_sync(serialQueue, ^{
        for (int i = 0; i < 5; i++) {
            NSLog(@"1:%d---%@", i, [NSThread currentThread]);
        }
    });
    dispatch_sync(serialQueue, ^{
        for (int i = 0; i < 5; i++) {
            NSLog(@"2:%d---%@", i, [NSThread currentThread]);
        }
    });
    dispatch_sync(serialQueue, ^{
        for (int i = 0; i < 5; i++) {
            NSLog(@"3:%d---%@", i, [NSThread currentThread]);
        }
    });
    
    
    NSLog(@"------sycnSerial__end-----");
    
    
}
//4.串行队列 + 异步执行:开启新的线程(1条),串行执行任务(开启了一条新线程,但是任务还是串行,所以任务是一个一个执行。任务不是马上执行,而是将所有任务添加到队列之后才开始同步执行)
- (void)asyncSerial {
    NSLog(@"------asycnSerial__start-----");
    dispatch_queue_t serialQueue = dispatch_queue_create("serialQueue", DISPATCH_QUEUE_SERIAL);
    
    dispatch_async(serialQueue, ^{
        for (int i = 0; i < 5; i++) {
            NSLog(@"1:%d---%@", i, [NSThread currentThread]);
        }
    });
    dispatch_async(serialQueue, ^{
        for (int i = 0; i < 5; i++) {
            NSLog(@"2:%d---%@", i, [NSThread currentThread]);
        }
    });
    dispatch_async(serialQueue, ^{
        for (int i = 0; i < 5; i++) {
            NSLog(@"3:%d---%@", i, [NSThread currentThread]);
        }
    });
    
    
    NSLog(@"------asycnSerial__end-----");
    
    
}


//5.主队列 + 同步执行:没有开启新的线程,串行执行(程序卡死)
- (void)syncMain {
    NSLog(@"-------sycnMain--start");
    
    dispatch_queue_t mainQueue = dispatch_get_main_queue();
    
    dispatch_sync(mainQueue, ^{
        for (int i = 0; i < 5; i++) {
            NSLog(@"1:%d---%@", i, [NSThread currentThread]);
        }
    });
    dispatch_sync(mainQueue, ^{
        for (int i = 0; i < 5; i++) {
            NSLog(@"2:%d---%@", i, [NSThread currentThread]);
        }
    });
    dispatch_sync(mainQueue, ^{
        for (int i = 0; i < 5; i++) {
            NSLog(@"3:%d---%@", i, [NSThread currentThread]);
        }
    });
    
    NSLog(@"-------sycnMain--end");
}
//6.主队列 + 异步执行:没有开启新的线程,串行执行(异步执行,具备开启线程的能力,但因为是主队列,所以所有任务都在主线程中,并且一个接一个执行。任务不是马上执行,而是将所有任务添加到队列之后才开始同步执行。)
- (void)asyncMain {
    NSLog(@"-------asycnMain--start");
    
    dispatch_queue_t mainQueue = dispatch_get_main_queue();
    
    dispatch_async(mainQueue, ^{
        for (int i = 0; i < 5; i++) {
            NSLog(@"1:%d---%@", i, [NSThread currentThread]);
        }
    });
    dispatch_async(mainQueue, ^{
        for (int i = 0; i < 5; i++) {
            NSLog(@"2:%d---%@", i, [NSThread currentThread]);
        }
    });
    dispatch_async(mainQueue, ^{
        for (int i = 0; i < 5; i++) {
            NSLog(@"3:%d---%@", i, [NSThread currentThread]);
        }
    });
    
    NSLog(@"-------asycnMain--end");
}

#pragma mark - 线程通讯
- (void)communicate {
    
    dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
        for (int i = 0; i < 5; i++) {
            NSLog(@"%d---%@", i, [NSThread currentThread]);
        }
        
        dispatch_async(dispatch_get_main_queue(), ^{
            
            NSLog(@"主线程%@", [NSThread currentThread]);
        });
        
    });
    
}

#pragma mark - GCD栅栏方法
//执行完栅栏前面的操作之后,才执行栅栏操作,最后再执行栅栏后边的操作。
- (void)barrier {
    dispatch_queue_t concurrentQueue = dispatch_queue_create("conQueue", DISPATCH_QUEUE_CONCURRENT);
    
    dispatch_async(concurrentQueue, ^{
        NSLog(@"----1-----%@", [NSThread currentThread]);
    });
    dispatch_async(concurrentQueue, ^{
        NSLog(@"----2-----%@", [NSThread currentThread]);
    });
    dispatch_barrier_async(concurrentQueue, ^{
        NSLog(@"----barrier-----%@", [NSThread currentThread]);
    });
    dispatch_async(concurrentQueue, ^{
        NSLog(@"----3-----%@", [NSThread currentThread]);
    });
    dispatch_async(concurrentQueue, ^{
        NSLog(@"----4-----%@", [NSThread currentThread]);
    });
    
}

#pragma mark - GCD延迟执行
- (void)after {
    dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(2.0f * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
        NSLog(@"----after----");
    });
}

#pragma mark - GCD ONCE
- (void)dispatchOnce {
    static dispatch_once_t onceToken;
    dispatch_once(&onceToken, ^{
        NSLog(@"只执行一次的代码");
    });
}

#pragma mark - GCD的快速迭代方法
- (void)apply {
    dispatch_queue_t globalQueue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    dispatch_apply(6, globalQueue, ^(size_t index) {
        NSLog(@"%zd-----%@", index, [NSThread currentThread]);
    });
}

#pragma mark - GCD的队列组
//有时候我们会有这样的需求:分别异步执行2个耗时操作,然后当2个耗时操作都执行完毕后再回到主线程执行操作。这时候我们可以用到GCD的队列组。

//我们可以先把任务放到队列中,然后将队列放入队列组中。
//调用队列组的dispatch_group_notify回到主线程执行操作。
- (void)group {
    dispatch_group_t group = dispatch_group_create();
    dispatch_group_async(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
        NSLog(@"第一个耗时长的异步操作");
    });
    
    dispatch_group_async(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
        NSLog(@"第二个耗时长的异步操作");
    });
    
    dispatch_group_async(group, dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
        NSLog(@"第三个耗时长的异步操作");
    });
    
    dispatch_group_notify(group, dispatch_get_main_queue(), ^{
        NSLog(@"所有耗时长的操作执行完成,回到主线程");
    });
}

NSOperation

#pragma mark - NSOperation (NSInvocationOperation)
//在没有使用NSOperationQueue、单独使用NSBlockOperation的情况下,NSBlockOperation也是在主线程执行操作,并没有开启新线程
- (void)invocationOperation {
    NSInvocationOperation *operation = [[NSInvocationOperation alloc] initWithTarget:self selector:@selector(run) object:nil];
    [operation start];
}

- (void)run {
    NSLog(@"NSInvocationOperation: ---- %@", [NSThread currentThread]);
}

#pragma mark - NSOperation (NSBlockOperation)
//blockOperationWithBlock:方法中的操作是在主线程中执行的,
//而addExecutionBlock:方法中的操作是在其他线程中执行的
- (void)blockOperation {
    NSBlockOperation *operation = [NSBlockOperation blockOperationWithBlock:^{
        NSLog(@"1------%@", [NSThread currentThread]);
    }];
    
    [operation addExecutionBlock:^{
        NSLog(@"2------%@", [NSThread currentThread]);
    }];
    [operation addExecutionBlock:^{
        NSLog(@"3------%@", [NSThread currentThread]);
    }];
    [operation addExecutionBlock:^{
        NSLog(@"4------%@", [NSThread currentThread]);
    }];
    
    [operation start];
}

#pragma mark - NSOperationQueue
- (void)operationQueue {
    //获取主队列
    NSOperationQueue *mainQueue = [NSOperationQueue mainQueue];
    
    //其他队列
//    添加到这种队列中的任务(NSOperation),就会自动放到子线程中执行
//    同时包含了:串行、并发功能
    NSOperationQueue *otherQueue = [[NSOperationQueue alloc] init];
}

#pragma mark - OperationQueue
//NSOperation需要配合NSOperationQueue来实现多线程。
//NSInvocationOperation和NSOperationQueue结合后能够开启新线程,进行并发执行NSBlockOperation和NSOperationQueue也能够开启新线程,进行并发执行
- (void)addOperationQueue {
    //1.创建队列
    NSOperationQueue *queue = [[NSOperationQueue alloc] init];
    //2.创建操作
    NSInvocationOperation *invoOperation = [[NSInvocationOperation alloc] initWithTarget:self selector:@selector(run2) object:nil];
    invoOperation.name = @"invoOperation";
    
    NSBlockOperation *blockOperation = [NSBlockOperation blockOperationWithBlock:^{
        for (int i = 0; i < 3; ++i) {
            NSLog(@"1-----%@", [NSThread currentThread]);
        }
    }];
    blockOperation.name = @"blockOperation";
    
    //3.添加到队列中
    [queue addOperation:invoOperation];
    [queue addOperation:blockOperation];
}

- (void)run2 {
    for (int i = 0; i < 3; ++i) {
        NSLog(@"2-----%@", [NSThread currentThread]);
    }
}

#pragma mark - NSOperationQueue Block
//无需先创建任务,在block中添加任务,直接将任务block加入到队列中。
- (void)addOperationWithBlockToQueue {
    NSOperationQueue *queue = [[NSOperationQueue alloc] init];
    [queue addOperationWithBlock:^{
        for (int i = 0; i < 9; ++i) {
            NSLog(@"1-----%@", [NSThread currentThread]);
        }
    }];
    [queue addOperationWithBlock:^{
        for (int i = 0; i < 9; ++i) {
            NSLog(@"2-----%@", [NSThread currentThread]);
        }
    }];
}


#pragma mark - 串行和并行
//maxConcurrentOperationCount 最大并发数量,默认为-1,表示不进行限制
//maxConcurrentOperationCount == 1 串行执行
//maxConcurrentOperationCount  > 1 并行执行,很大时候系统自动调整
//当最大并发数为1时,任务是按顺序串行执行的。当最大并发数为2时,任务是并发执行的。而且开启线程数量是由系统决定的,不需要我们来管理
- (void)maxConcurrentOperationCount
{
    // 创建队列
    NSOperationQueue *queue = [[NSOperationQueue alloc] init];
    
    // 设置最大并发操作数
    //    queue.maxConcurrentOperationCount = 2;
    queue.maxConcurrentOperationCount = 3; // 就变成了串行队列
    
    // 添加操作
    [queue addOperationWithBlock:^{
        NSLog(@"1-----%@", [NSThread currentThread]);
        [NSThread sleepForTimeInterval:0.01];
    }];
    [queue addOperationWithBlock:^{
        NSLog(@"2-----%@", [NSThread currentThread]);
        [NSThread sleepForTimeInterval:0.01];
    }];
    [queue addOperationWithBlock:^{
        NSLog(@"3-----%@", [NSThread currentThread]);
        [NSThread sleepForTimeInterval:0.01];
    }];
    [queue addOperationWithBlock:^{
        NSLog(@"4-----%@", [NSThread currentThread]);
        [NSThread sleepForTimeInterval:0.01];
    }];
    [queue addOperationWithBlock:^{
        NSLog(@"5-----%@", [NSThread currentThread]);
        [NSThread sleepForTimeInterval:0.01];
    }];
    
    [queue addOperationWithBlock:^{
        NSLog(@"6-----%@", [NSThread currentThread]);
        [NSThread sleepForTimeInterval:0.01];
    }];
}

#pragma mark - 依赖操作
- (void)addDependency {
    NSOperationQueue *queue = [[NSOperationQueue alloc] init];
    
    NSBlockOperation *op1 = [NSBlockOperation blockOperationWithBlock:^{
        NSLog(@"1-----%@", [NSThread  currentThread]);
    }];
    
    NSBlockOperation *op2 = [NSBlockOperation blockOperationWithBlock:^{
        NSLog(@"2-----%@", [NSThread  currentThread]);
    }];
    
    NSBlockOperation *op3 = [NSBlockOperation blockOperationWithBlock:^{
        NSLog(@"3-----%@", [NSThread  currentThread]);

//        [op2 cancel];
        
        
    }];
    
    NSBlockOperation *op4 = [NSBlockOperation blockOperationWithBlock:^{
        NSLog(@"4-----%@", [NSThread  currentThread]);
        
        [queue cancelAllOperations];
    }];
    
    //op1 依赖于op3 ,只有op3结束以后才能执行op1
    [op1 addDependency:op3];
    [op2 addDependency:op4];
    
    [queue addOperation:op1];
    [queue addOperation:op2];
    [queue addOperation:op3];
    [queue addOperation:op4];
}
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 213,992评论 6 493
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,212评论 3 388
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 159,535评论 0 349
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,197评论 1 287
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,310评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,383评论 1 292
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,409评论 3 412
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,191评论 0 269
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,621评论 1 306
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,910评论 2 328
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,084评论 1 342
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,763评论 4 337
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,403评论 3 322
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,083评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,318评论 1 267
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,946评论 2 365
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,967评论 2 351

推荐阅读更多精彩内容