多线程

2017-06-18  本文已影响12人  随意啊

1.何为多线程

  • 多线程是一个应用程序同时执行多个任务,线程是执行程序的最基本单元,他有自己的栈和寄 存器,线程既是一个CPU执行的无分叉的命令列。多个任务即意味着有多组栈和寄存器中的值需要不断地被备份、替换。因此多线程本身会带来效率上的损失,不考虑其他任何因素和技术多线程是会降低效率的。
  • 准确来说,在处理并发任务时,多线程不仅不能提高效率,反而还会降低程序效率

2. 并发和并行

  • 并发指的是一种现象,一种经常出现,无可避免的现象,它描述的是“多个任务同时发生,需要被处理” 这一现象,它的侧重点在与发生。
比如很多人排队等待检票,这一现象就可以理解为并发
  • 并行指的是一种技术,一个同时处理多个任务的技术,他描述了一种同时能够处理多个任务的能力,侧重点在于“运行”
比如景点开放了多个检票窗口,同一时间内服务多个游客,这种情况可以理解为并行。

*我们经常挂在嘴边的“多线程”,正是采用了并行技术,从而提高了执行效率。因为有多个线程,所以计算机的多个CPU可以同时工作,同时处理不同线程内的指令。

并发是一种现象,面对这一现象,我们首先创建多个线程,真正加快程序运行速度的,是并行技术。也就是让多个CPU同时工作。而多线程,是为了让多个CPU同时工作成为可能

3.总结

于是我们可以得出结论,在需要同时处理IO和UI的情况下,真正起作用的是异步,而不是多线程,可以不用多线程,但是不能不用异步

2.常用的多线程方案 NSThread、GCD、NSOperation & NSOperationQueue

1.NSThread

NSThread是Objective-C的基础框架的一部分,并为开发者提供一种方法来创建和管理线程

特点:

示例 NSThread:
- (void)creatThread{
    NSThread *thread =[[NSThread alloc]initWithTarget:self selector:@selector(runThead) object:nil];
    [thread start];
     /* 创建并且自动启动 */
    [NSThread detachNewThreadSelector:@selector(runThead2) toTarget:self withObject:nil];
     /* 使用 NSObject 的方法创建并自动启动 */
    [self performSelectorInBackground:@selector(runThead3) withObject:nil];
}

- (void)runThead{
    NSLog(@"创建线程1:%@", [NSThread currentThread]);
}
- (void)runThead2{
     NSLog(@"自动启动线程2%@", [NSThread currentThread]);
}
- (void)runThead3{
     NSLog(@"自动启动线程3%@", [NSThread currentThread]);
}

2.GCD

GCD为Grand Central Dispatch的缩写 它是苹果为多核的并行运算提出的解决方案,所以会自动合理地利用更多的CPU内核(比如双核、四核),最重要的是它会自动管理线程的生命周期(创建线程、调度任务、销毁线程),完全不需要我们管理,我们只需要告诉干什么就行。同时它使用的也是 c语言,不过由于使用了 Block(Swift里叫做闭包),使得使用起来更加方便,而且灵活

1. 任务和队列

在 GCD 中,加入了两个非常重要的概念: 任务 和 队列。

任务:即操作,你想要干什么,说白了就是一段代码,在 GCD 中就是一个 Block,所以添加任务十分方便。任务有两种执行方式: 同步执行 和 异步执行,他们之间的区别是 是否会创建新的线程。

同步和异步

<strong>同步(sync)</strong> 和 <strong>异步(async)</strong>的主要区别在于会不会阻塞当前线程,知道block中的任务执行完毕!

<strong>同步(sync)</strong>操作,他会阻塞当前线程并等待block中的任务执行完毕,然后当前线程才会继续往下运行。

<strong>异步(async)</strong>当前线程会直接往下执行,它不会阻塞当前线程

同步 异步
主队列 在主线程执行 在主线程执行
串行队列 在当前线程执行 新建线程执行
并发队列 在当前线程执行 新建线程执行
dispatch_queue_t aQueue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);

清理函数

在创建 dispatch queue 之后,可以附加一个 finalizer 函数,在 queue 被销毁之前执行自定义的清理操作。使用dispatch_set_finalizer_f 函数为 queue 指定一个清理函数,当 queue 的引用计数到达 0 时(ARC 下虽然你看不到了但是原理依然如此),且只有上下文指针不为 NULL 时才会调用这个清理函数。

添加单个任务到Queue

你可以异步或同步地添加一个任务到 Queue(异步与同步的区别就是是否阻塞当前线程)。

尽可能地使用 <strong>dispatch_async 或 dispatch_async_f </strong>函数<font color =red>异步</font>地 dispatch 任务。因为添加任务到 Queue 中时,无法确定这些代码什么时候能够执行。因此异步地添加 block 或函数,可以让你立即调度这些代码的执行,然后调用线程可以继续去做其它事情

2. GCD的死锁问题

在使用GCD的过程中,如果向当前串行队列中同步派发一个任务,就会导致死锁

绝对不要在任务中调用 dispatch_sync 或 dispatch_sync_f 函数,并同步 dispatch 新任务到当前正在执行的 queue。对于串行 queue 这一点特别重要,因为这样做肯定会导致死锁;而并发 queue 也应该避免这样做,否则虽然并发 queue 不去引起运行时错误,但是被锁的部分永远不会被执行到

解决方案
  • 其实在通常情况下我们不必要用dispatch_sync,因为dispatch_async能够更好的利用CPU,提升程序运行速度。
 dispatch_queue_t queue = dispatch_queue_create("", NULL);
  dispatch_queue_t queue = dispatch_queue_create("test.Lision.testQueue", DISPATCH_QUEUE_SERIAL);
 dispatch_queue_t queue = dispatch_queue_create("test.Lision.testQueue", DISPATCH_QUEUE_CONCURRENT);
- (void)lockGCD{
    dispatch_queue_t myCustomQueue =dispatch_queue_create("test.myCustomQueue", NULL);
    /* 异步执行 */
    dispatch_async(myCustomQueue, ^{
        NSLog(@"Do some work here.\n");
    });
    NSLog(@"The first block may or may not have run.\n");
     /* 同步执行 */
    dispatch_sync(myCustomQueue, ^{
        NSLog(@"同步非主队列");
    });
    // 由于上面的操作是同步操作会阻塞当前线程,所以执行下面的打印时上面的操作肯定是已经完毕的
    NSLog(@"同步非主队列Both blocks have completed.\n");
     /* 如国是当前线程同步执行则会引发死锁 */
    dispatch_queue_t myMainQueue =dispatch_get_main_queue();
    dispatch_sync(myMainQueue, ^{
          NSLog(@"同步主队列");
    });
     NSLog(@"同步主队列Both blocks have completed.\n");
}
3. Dispatch Queue 和线程安全性

使用 Dispatch Queue 实现应用并发时,也需要注意线程安全性

4.Dispatch Semaphore(信号量)

类似于传统的 semaphore(信号量),但是更加高效。只有当调用线程由于信号量不可用,需要阻塞时,Dispatch semaphore 才会去调用内核。如果信号量可用,就不会与内核进行交互
使用信号量可以实现对有限资源的访问控制

使用 Dispatch Semaphore 的过程如下:

  1. 使用 dispatch_semaphore_create 函数创建 semaphore,指定正数值表示 资源的可用数量
  2. 在每个任务中,调用 dispatch_semaphore_wait 来等待 semaphore
  3. 当上面调用返回时,获得资源并开始工作
  4. 使用完资源后,调用 dispatch_semaphore_signal 函数释放和 signal 这个 semaphore
#pragma mark GCD dispatch_semaphore_t信号量
- (void)semaphoreTest{
   dispatch_group_t group = dispatch_group_create();
   dispatch_queue_t mySemaphoreQueue =dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
   // 创建信号 3标识资源可用数量 
   //  某个线程执行到这里,如果信号量值为1,那么wait方法返回1,开始执行接下来的操作。
    与此同时,因为信号量变为0,其它执行到这里的线程都必须等待 */
   dispatch_semaphore_t mySemaphore =dispatch_semaphore_create(3);
   
   // 等待一个可用的文件描述符 
  <!--  执行了wait方法后,信号量的值变成了0。可以进行接下来的操作。
    这时候其它线程都得等待wait方法返回。
    可以对array修改的线程在任意时刻都只有一个,可以安全的修改array-->
   for (int i =0; i<30; i++) {
       dispatch_semaphore_wait(mySemaphore, DISPATCH_TIME_FOREVER);
       dispatch_async(mySemaphoreQueue, ^{
           [NSThread sleepForTimeInterval:5];//模拟代码执行时间
           NSLog(@"等待----执行工作 %d",i);
           /*
            排他操作执行结束,记得要调用signal方法,把信号量的值加1。
            这样,如果有别的线程在等待wait函数返回,就由最先等待的线程执行。  */
           dispatch_semaphore_signal(mySemaphore);
       });
       
   }
   dispatch_group_wait(group, DISPATCH_TIME_FOREVER);
}

5.dispatch_group_notify

dispatch_group 执行完一组异步操作后可以通过 dispatch_group_notify来通知主线程,反馈信息给用户

- (void)group_notify_Test{
   dispatch_queue_t queue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
   dispatch_group_t group =dispatch_group_create();
   // 把 queue 加入到 group
   dispatch_group_async(group, queue, ^{
       dispatch_async(queue, ^{
            [NSThread sleepForTimeInterval:5];//模拟代码执行时间
            [NSThread sleepForTimeInterval:15];//模拟代码执行时间
            [NSThread sleepForTimeInterval:2];//模拟代码执行时间
           NSLog(@"模拟代码完成");
       });
   });
   dispatch_group_notify(group, dispatch_get_main_queue(), ^(){
       // 从主线程上执行 UI 界面更新
       NSLog(@"从主线程上执行 UI 界面更新");
   });
}

<font color =red>iOS AFNetworking 多个网络请求顺序返回数据</font>

采用信号量机制顺序打印

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);

    for (int i=0; i<100; i++) {

        //信号量减1,如果同时开启1个以上的线程,则信号量小于等于0,此时就会阻塞该线程。

        dispatch_semaphore_wait(semaphore, DISPATCH_TIME_FOREVER);

        dispatch_group_async(group, queue, ^{

            NSLog(@"test %d",i);

        //每个线程执行减1后通过信号量通知加1,这样始终保持线程在10个之内

        dispatch_semaphore_signal(semaphore);

        });

    }

    dispatch_group_wait(group, DISPATCH_TIME_FOREVER);
    
   

3. NSOperation

描述
NSInvocationOperation 可以直接使用的类,基于应用的一个对象和 selector 来创建 operation object。如果你已经有现有的方法来执行需要的任务,就可以使用这个类
NSBlockOperation 可以直接使用的类,用来并发地执行一个或多个 block 对象。operation object 使用“组”的语义来执行多个 block 对象,所有相关的 block 都执行完成之后,operation object 才算完成。
NSOperation 基类,用来自定义子类 operation object。继承 NSOperation 可以完全控制 operation object 的实现,包括修改操作执行和状态报告的方式

-(void)InvocationOperation_Test{
    NSInvocationOperation *invocation =[[NSInvocationOperation alloc]initWithTarget:self selector:@selector(operationTest) object:nil];
    [invocation start];
}

- (void)blockOperation_Test{
   NSBlockOperation *blockOperation =[NSBlockOperation blockOperationWithBlock:^{
       NSLog(@"do code");
   }];
}

- (void)operationTest{

}
上一篇下一篇

猜你喜欢

热点阅读