iOS—— 多线程之pthreadNSThread

Posted zxb10

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了iOS—— 多线程之pthreadNSThread相关的知识，希望对你有一定的参考价值。

文章目录


在ios中多线程开发有四种方式，在之前我们浅浅了解了一下GCD，这期来看看pthread和NSThread。

1.pthread

pthread简介：

pthread 是一套通用的多线程的 API，可以在Unix / Linux / Windows 等系统跨平台使用，使用 C 语言编写，需要程序员自己管理线程的生命周期，使用难度较大。
POSIX 线程（英语：POSIX Threads，常被缩写 为 Pthreads）是 POSIX 的线程标准，定义了创建和操纵线程的一套 API。
实现 POSIX 线程标准的库常被称作 Pthreads，一般用于 Unix-like POSIX 系统，如 Linux、Solaris。但是 Microsoft Windows 上的实现也存在，例如直接使用 Windows API 实现的第三方库 pthreads-w32；而利用 Windows 的 SFU/SUA 子系统，则可以使用微软提供的一部分原生 POSIX API。（维基百科）

pthread使用方法

1.首先要包含头文件#import <pthread.h>
2.其次要创建线程，并开启线程执行任务

#import <Foundation/Foundation.h>
#import <pthread.h>
void *run(void *param) 
    for (NSInteger i = 0; i < 5; i++) 
            NSLog(@"%ld-> %@", i, [NSThread currentThread]);
        
    return NULL;


int main(int argc, const char * argv[]) 
    @autoreleasepool 
        pthread_t myThread;
        int res = pthread_create(&myThread, NULL, run, NULL);
        if (res == 0) 
            NSLog(@"创建线程成功!");
        
        // 线程结束后释放所有资源
        pthread_detach(myThread);
        NSLog(@"%@", [NSThread currentThread]);
    
    return 0;

运行结果：

pthread_create(&thread, NULL, run, NULL); 中各项参数含义：

  • 第一个参数&thread是线程对象，指向线程标识符的指针
  • 第二个是线程属性，可赋值NULL
  • 第三个run表示指向函数的指针(run对应函数里是需要在新线程中执行的任务)
  • 第四个是运行函数的参数，可赋值NULL

pthread 其他相关方法

  • pthread_create() 创建一个线程
  • pthread_exit() 终止当前线程
  • pthread_cancel() 中断另外一个线程的运行
  • pthread_join() 阻塞当前的线程，直到另外一个线程运行结束
  • pthread_attr_init() 初始化线程的属性
  • pthread_attr_setdetachstate() 设置脱离状态的属性（决定这个线程在终止时是否可以被结合）
  • pthread_attr_getdetachstate() 获取脱离状态的属性
  • pthread_attr_destroy() 删除线程的属性
  • pthread_kill() 向线程发送一个信号

2.NSThread

NSThread 是苹果官方提供的，使用起来比 pthread 更加面向对象，简单易用，可以直接操作线程对象。不过也需要需要程序员自己管理线程的生命周期(主要是创建)，我们在开发的过程中偶尔使用 NSThread。比如我们会经常调用[NSThread currentThread]来显示当前的进程信息。

创建，启动线程

  • 先创建线程，再启动线程
// 1. 创建线程
NSThread *thread = [[NSThread alloc] initWithTarget:self selector:@selector(run) object:nil];
// 2. 启动线程
[thread start];    // 线程一启动，就会在线程thread中执行self的run方法

// 新线程调用方法，里边为需要执行的任务
- (void)run 
     NSLog(@"%@", [NSThread currentThread]);
  • 创建线程后自动启动线程
// 1. 创建线程后自动启动线程
[NSThread detachNewThreadSelector:@selector(run) toTarget:self withObject:nil];

// 新线程调用方法，里边为需要执行的任务
- (void)run 
     NSLog(@"%@", [NSThread currentThread]);
  • 隐式创建并启动线程
// 1. 隐式创建并启动线程
[self performSelectorInBackground:@selector(run) withObject:nil];

// 新线程调用方法，里边为需要执行的任务
- (void)run 
     NSLog(@"%@", [NSThread currentThread]);

线程相关用法

// 获得主线程
+ (NSThread *)mainThread;    

// 判断是否为主线程(对象方法)
- (BOOL)isMainThread;

// 判断是否为主线程(类方法)
+ (BOOL)isMainThread;    

// 获得当前线程
NSThread *current = [NSThread currentThread];

// 线程的名字——setter方法
- (void)setName:(NSString *)n;    

// 线程的名字——getter方法
- (NSString *)name;

线程相关用法

// 获得主线程
+ (NSThread *)mainThread;    

// 判断是否为主线程(对象方法)
- (BOOL)isMainThread;

// 判断是否为主线程(类方法)
+ (BOOL)isMainThread;    

// 获得当前线程
NSThread *current = [NSThread currentThread];

// 线程的名字——setter方法
- (void)setName:(NSString *)n;    

// 线程的名字——getter方法
- (NSString *)name;

线程状态控制方法

  • 启动线程方法
- (void)start;
// 线程进入就绪状态 -> 运行状态。当线程任务执行完毕，自动进入死亡状态
  • 阻塞（暂停）线程方法
+ (void)sleepUntilDate:(NSDate *)date;
+ (void)sleepForTimeInterval:(NSTimeInterval)ti;
// 线程进入阻塞状态
  • 强制停止线程
+ (void)exit;
// 线程进入死亡状态

线程之间的通信

在开发中，我们经常会在子线程进行耗时操作，操作结束后再回到主线程去刷新 UI。这就涉及到了子线程和主线程之间的通信。我们先来了解一下官方关于 NSThread 的线程间通信的方法。

// 在主线程上执行操作
- (void)performSelectorOnMainThread:(SEL)aSelector withObject:(id)arg waitUntilDone:(BOOL)wait;
- (void)performSelectorOnMainThread:(SEL)aSelector withObject:(id)arg waitUntilDone:(BOOL)wait modes:(NSArray<NSString *> *)array;
  // equivalent to the first method with kCFRunLoopCommonModes

// 在指定线程上执行操作
- (void)performSelector:(SEL)aSelector onThread:(NSThread *)thr withObject:(id)arg waitUntilDone:(BOOL)wait modes:(NSArray *)array NS_AVAILABLE(10_5, 2_0);
- (void)performSelector:(SEL)aSelector onThread:(NSThread *)thr withObject:(id)arg waitUntilDone:(BOOL)wait NS_AVAILABLE(10_5, 2_0);

// 在当前线程上执行操作，调用 NSObject 的 performSelector:相关方法
- (id)performSelector:(SEL)aSelector;
- (id)performSelector:(SEL)aSelector withObject:(id)object;
- (id)performSelector:(SEL)aSelector withObject:(id)object1 withObject:(id)object2;

举例一个加载图片的demo：

/**
 * 创建一个线程下载图片
 */
- (void)downloadImageOnSubThread 
    // 在创建的子线程中调用downloadImage下载图片
    [NSThread detachNewThreadSelector:@selector(downloadImage) toTarget:self withObject:nil];


/**
 * 下载图片，下载完之后回到主线程进行 UI 刷新
 */
- (void)downloadImage 
    NSLog(@"current thread -- %@", [NSThread currentThread]);
    
    // 1. 获取图片 imageUrl
    NSURL *imageUrl = [NSURL URLWithString:@"https://ysc-demo-1254961422.file.myqcloud.com/YSC-phread-NSThread-demo-icon.jpg"];
    
    // 2. 从 imageUrl 中读取数据(下载图片) -- 耗时操作
    NSData *imageData = [NSData dataWithContentsOfURL:imageUrl];
    // 通过二进制 data 创建 image
    UIImage *image = [UIImage imageWithData:imageData];
    
    // 3. 回到主线程进行图片赋值和界面刷新
    [self performSelectorOnMainThread:@selector(refreshOnMainThread:) withObject:image waitUntilDone:YES];


/**
 * 回到主线程进行图片赋值和界面刷新
 */
- (void)refreshOnMainThread:(UIImage *)image 
    NSLog(@"current thread -- %@", [NSThread currentThread]);
    
    // 赋值图片到imageview
    self.imageView.image = image;

NSThread线程安全和线程同步

线程安全：如果你的代码所在的进程中有多个线程在同时运行，而这些线程可能会同时运行这段代码。如果每次运行结果和单线程运行的结果是一样的，而且其他的变量的值也和预期的是一样的，就是线程安全的。

若每个线程中对全局变量、静态变量只有读操作，而无写操作，一般来说，这个全局变量是线程安全的；若有多个线程同时执行写操作（更改变量），一般都需要考虑线程同步，否则的话就可能影响线程安全。

线程同步：可理解为线程 A 和 线程 B 一块配合，A 执行到一定程度时要依靠线程 B 的某个结果，于是停下来，示意 B 运行；B 依言执行，再将结果给 A；A 再继续操作。

举个简单例子就是：两个人在一起聊天。两个人不能同时说话，避免听不清(操作冲突)。等一个人说完(一个线程结束操作)，另一个再说(另一个线程再开始操作)。

下面，我们模拟火车票售卖的方式，实现 NSThread 线程安全和解决线程同步问题。

场景：总共有50张火车票，有两个售卖火车票的窗口，一个是北京火车票售卖窗口，另一个是上海火车票售卖窗口。两个窗口同时售卖火车票，卖完为止。

NSThread 非线程安全


/**
 * 初始化火车票数量、卖票窗口(非线程安全)、并开始卖票
 */
- (void)initTicketStatusNotSave 
    // 1. 设置剩余火车票为 10
    self.ticketSurplusCount = 10;
    
    // 2. 设置北京火车票售卖窗口的线程
    self.ticketSaleWindow1 = [[NSThread alloc]initWithTarget:self selector:@selector(saleTicketNotSafe) object:nil];
    self.ticketSaleWindow1.name = @"北京火车票售票窗口";
    
    // 3. 设置上海火车票售卖窗口的线程
    self.ticketSaleWindow2 = [[NSThread alloc]initWithTarget:self selector:@selector(saleTicketNotSafe) object:nil];
    self.ticketSaleWindow2.name = @"上海火车票售票窗口";
    
    // 4. 开始售卖火车票
    [self.ticketSaleWindow1 start];
    [self.ticketSaleWindow2 start];



/**
 * 售卖火车票(非线程安全)
 */
- (void)saleTicketNotSafe 
    while (1) 
        //如果还有票，继续售卖
        if (self.ticketSurplusCount > 0) 
            self.ticketSurplusCount --;
            NSLog(@"%@", [NSString stringWithFormat:@"剩余票数：%d 窗口：%@", self.ticketSurplusCount, [NSThread currentThread].name]);
            [NSThread sleepForTimeInterval:0.2];
        
        //如果已卖完，关闭售票窗口
        else 
            NSLog(@"所有火车票均已售完");
            break;

两个线程相互竞争，得到票数是错乱的，这样显然不符合我们的需求，所以我们需要考虑线程安全问题。

输出结果：

NSThread 线程安全

线程安全解决方案：可以给线程加锁，在一个线程执行该操作的时候，不允许其他线程进行操作。iOS 实现线程加锁有很多种方式。@synchronized、 NSLock、NSRecursiveLock、NSCondition、NSConditionLock、pthread_mutex、dispatch_semaphore、OSSpinLock、atomic(property) set/ge等等各种方式。为了简单起见，这里不对各种锁的解决方案和性能做分析，只用最简单的@synchronized来保证线程安全，从而解决线程同步问题。

/**
 * 初始化火车票数量、卖票窗口(线程安全)、并开始卖票
 */
- (void)initTicketStatusSave 
    // 1. 设置剩余火车票为 10
    self.ticketSurplusCount = 10;
    
    // 2. 设置北京火车票售卖窗口的线程
    self.ticketSaleWindow1 = [[NSThread alloc]initWithTarget:self selector:@selector(saleTicketSafe) object:nil];
    self.ticketSaleWindow1.name = @"北京火车票售票窗口";
    
    // 3. 设置上海火车票售卖窗口的线程
    self.ticketSaleWindow2 = [[NSThread alloc]initWithTarget:self selector:@selector(saleTicketSafe) object:nil];
    self.ticketSaleWindow2.name = @"上海火车票售票窗口";
    
    // 4. 开始售卖火车票
    [self.ticketSaleWindow1 start];
    [self.ticketSaleWindow2 start];
    


/**
 * 售卖火车票(线程安全)
 */
- (void)saleTicketSafe 
    while (1) 
        // 互斥锁
        @synchronized (self) 
            //如果还有票，继续售卖
            if (self.ticketSurplusCount > 0) 
                self.ticketSurplusCount --;
                NSLog(@"%@", [NSString stringWithFormat:@"剩余票数：%d 窗口：%@", self.ticketSurplusCount, [NSThread currentThread].name]);
                [NSThread sleepForTimeInterval:0.2];
            
            //如果已卖完，关闭售票窗口
            else 
                NSLog(@"所有火车票均已售完");
                break;

输出结果：

两秒卖一次票，不会造成竞争。

线程的状态转换

当我们新建一条线程NSThread *thread = [[NSThread alloc] initWithTarget:self selector:@selector(run) object:nil];，在内存中的表现为：

当调用[thread start];后，系统把线程对象放入可调度线程池中，线程对象进入就绪状态，如下图所示。

当然，可调度线程池中，会有其他的线程对象，如下图所示。在这里我们只关心左边的线程对象。
下边我们来看看当前线程的状态转换：

  • 如果CPU现在调度当前线程对象，则当前线程对象进入运行状态，如果CPU调度其他线程对象，则当前线程对象回到就绪状态。
  • 如果CPU在运行当前线程对象的时候调用了sleep方法\\等待同步锁，则当前线程对象就进入了阻塞状态，等到sleep到时\\得到同步锁，则回到就绪状态。
  • 如果CPU在运行当前线程对象的时候线程任务执行完毕\\异常强制退出，则当前线程对象进入死亡状态。

如下图所示：

NSThread线程属性

name属性：设置线程的名字

NSThread *thread = [[NSThread alloc] initWithBlock:^
    NSLog(@"线程：%@ start",[NSThread currentThread]);
 ];
thread.name = @"测试线程";
[thread start];

qualityOfService属性：设置线程优先级

typedef NS_ENUM(NSInteger, NSQualityOfService) 
    NSQualityOfServiceUserInteractive = 0x21,
    NSQualityOfServiceUserInitiated = 0x19,
    NSQualityOfServiceUtility = 0x11,
    NSQualityOfServiceBackground = 0x09,
    NSQualityOfServiceDefault = -1
 API_AVAILABLE(macos(10.10), ios(8.0), watchos(2.0), tvos(9.0));

NSQualityOfServiceUserInteractive 优先级最高，从上到下依次降低，NSQualityOfServiceDefault 为默认优先级。

测试：

//qualityOfService属性：设置线程优先级
- (void)qualityOfServiceStudy 
    NSThread *thread1 = [[NSThread alloc] initWithBlock:^
        NSLog(@"\\n 线程：%@ start",[NSThread currentThread]);
    ];
    thread1.name = @"测试线程 1 ";
    [thread1 start];
    
    NSThread *thread2 = [[NSThread alloc] initWithBlock:^
        NSLog(@"\\n 线程：%@ start",[NSThread currentThread]);
    ];
    thread2.qualityOfService = NSQualityOfServiceUserInteractive;
    thread2.name = @"测试线程 2 ";
    [thread2 start];

虽然 thread1 先于 thread2 start，但thread1优先级为默认，而thread2优先级为NSQualityOfServiceUserInteractive，在执行时，thread2 先于 thread1执行。

其他属性

  • @property (class, readonly, copy) NSArray<NSNumber *> *callStackReturnAddresses //线程的调用会有函数的调用，该属性返回的就是 该线程中函数调用的虚拟地址数组。
  • @property (class, readonly, copy) NSArray<NSString *> *callStackSymbols。 //该属性以符号的形式返回该线程调用函数。

callStackReturnAddress和callStackSymbols这两个函数可以同NSLog联合使用来跟踪线程的函数调用情况，是编程调试的重要手段。

  • @property (readonly, retain) NSMutableDictionary *threadDictionary; //每个线程有自己的堆栈空间，线程内维护了一个键-值的字典，它可以在线程里面的任何地方被访问。
    你可以使用该字典来保存一些信息，这些信息在整个线程的执行过程中都保持不变。
    比如,你可以使用它来存储在你的整个线程过程中 Run loop 里面多次迭代的状态信息。
  • @property (class, readonly, strong) NSThread *mainThread; // 获取主线程
  • @property (class, readonly, strong) NSThread *currentThread;// 获取当前线程
  • @property NSUInteger stackSize; // 线程使用堆栈大小，默认512k
  • @property (readonly) BOOL isMainThread; // 是否是主线程
  • @property (class, readonly) BOOL isMainThread ; // reports whether current thread is main
  • @property (readonly, getter=isExecuting) BOOL executing ; // 线程是否正在执行
  • @property (readonly, getter=isFinished) BOOL finished ; // 线程是否执行完毕
  • @property (readonly, getter=isCancelled) BOOL cancelled; // 线程是否取消

iOS---多线程实现方案一 (pthreadNSThread)

在iOS开发中，多线程是我们在开发中经常使用的一门技术。那么本文章将和大家探讨一下针对于多线程的技术实现。本文主要分为如下几个部分:

  • iOS开发中实现多线程的方式

  • 单线程

  • pthread

  • NSThread

     

     

 

一、iOS开发中实现多线程的方式

  • pthread: 跨平台，适用于多种操作系统，可移植性强，是一套纯C语言的通用API，且线程的生命周期需要程序员自己管理，使用难度较大，所以在实际开发中通常不使用。

  • NSThread: 基于OC语言的API，使得其简单易用，面向对象操作。线程的声明周期由程序员管理，在实际开发中偶尔使用。

  • GCD: 基于C语言的API，充分利用设备的多核，旨在替换NSThread等线程技术。线程的生命周期由系统自动管理，在实际开发中经常使用。

  • NSOperation: 基于OC语言API，底层是GCD，增加了一些更加简单易用的功能，使用更加面向对象。线程生命周期由系统自动管理，在实际开发中经常使用。

 

二、单线程

进程，线程的概念就不在此文进行介绍了。至于提到单线程，只是想跟大家聊一聊如果没有多线程开发我们的项目将是怎么样的。作为一个ios开发人员，大家都知道主线程是用来刷新UI的，而线程又是串行的。也就是说，我们的程序运行在主线程上，如果此时迎来了一些耗时操作的时候，我们的手机屏幕会卡住，所以多线程开发是很必要的。本文的ThreadDemo工作组中有一个在主线程耗时操作的demo，名称为TimeConsumingDemo。大家看一下就好了，demo很简单，写在这里的目的也是希望能给读者一个直观的感受。

 

三、pthread

pthread这个方案在这里只为大家了解，可能很多linux开发人员在使用这种方案进行多线程开发操作。不过对于我来讲在ios开发中我一次都没用过。


使用pthread 要引入头文件

#import <pthread.h>

然后创建线程

pthread_t thread = NULL;

id str = @"i‘m pthread param";

pthread_create(&thread, NULL, operate, (__bridge void *)(str));

pthread_create的函数原型为

int pthread_create(pthread_t * __restrict, const pthread_attr_t * __restrict,

  void *(*)(void *), void * __restrict);

第一个参数pthread_t * __restrict
由于c语言没有对象的概念，所以pthread_t实际是一个结构体
所以创建的thread是一个指向当前新建线程的指针

typedef __darwin_pthread_t pthread_t;

typedef struct _opaque_pthread_t *__darwin_pthread_t;

struct _opaque_pthread_t {

      long __sig;

      struct __darwin_pthread_handler_rec  *__cleanup_stack;

      char __opaque[__PTHREAD_SIZE__];

};

第二个参数const pthread_attr_t * __restrict
同样是一个结构体，这里是用来设置线程属性的

 

typedef __darwin_pthread_attr_t pthread_attr_t;

typedef struct _opaque_pthread_attr_t __darwin_pthread_attr_t;

struct _opaque_pthread_attr_t {

    long __sig;

    char __opaque[__PTHREAD_ATTR_SIZE__];

};

第三个参数void ()(void *)这里给出了一个函数指针，指向的是一个函数的起始地址，所以是线程开启后的回调函数，这里demo给出的是operate函数，在线程中进行耗时操作。
第四个参数是回调函数所用的参数

 

void *operate(void *param) {

    NSString *str = (__bridge NSString *)(param);

    // 用循环模拟耗时操作

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

        // [NSThread currentThread] 为获取当前

        NSLog(@"timeConsuming in %@, times: %d, param: %@", [NSThread currentThread], i, str);

    }

    pthread_exit((void*)0);

}

那么，Pthreads在这里就介绍这么多，要注意的一点是在使用Pthreads的时候一定要手动把当前线程结束掉。因为我们经常使用的GCD和NSOperation已经被苹果封装过了，所以我们想要定制进行线程的操作就会有一定限制，如果有想从底层进行定制的读者，可以去搜一下相关的资料。

 

四、 NSThread

NSThread由苹果进行了封装，并且完全面向对象。所以可以直接使用OC方法操控线程对象，非常直观和方便。可以说对于ios开发人员而言，使用NSThread就开始了真正的多线程开发。所以，通过NSThread我们具体讨论一些线程相关的问题，包括如下内容：

  • 使用NSThread创建线程

  • 线程状态

  • 线程间通信

  • 线程安全

 

1. 使用NSThread创建线程

使用NSThread创建线程有以下几种方式:

  1. 使用NSThread的init方法显式创建

  2. 使用NSThread类方法显式创建并启动线程

  3. 隐式创建并启动线程

具体的代码实现在下面已经给出了，这里提醒大家注意一点。只有使用NSThread的init方法创建的线程才会返回具体的线程实例。也就是说如果想要对线程做更多的控制，比如添加线程的名字、更改优先级等操作，要使用第一种方式来创建线程。但是此种方法需要使用start方法来手动启动线程。

/**

 *  隐式创建并启动线程

 */

- (void)createThreadWithImplicit {

    // 隐式创建并启动线程

    [self performSelectorInBackground:@selector(threadMethod3:) withObject:@"implicitMethod"];

}

 

/**

 *  使用NSThread类方法显式创建并启动线程

 */

- (void)createThreadWithClassMethod {

    // 使用类方法创建线程并自动启动线程

    [NSThread detachNewThreadSelector:@selector(threadMethod2:) toTarget:self withObject:@"fromClassMethod"];

}

 

/**

 *  使用init方法显式创建线程

 */

- (void)createThreadWithInit {

    // 创建线程

    NSThread *thread1 = [[NSThread alloc] initWithTarget:self selector:@selector(threadMethod1) object:nil];

    // 设置线程名

    [thread1 setName:@"thread1"];

    // 设置优先级 优先级从0到1 1最高

    [thread1 setThreadPriority:0.9];

    // 启动线程

    [thread1 start];

}

2. 线程状态

线程状态分为：启动线程， 阻塞线程，结束线程
启动线程:

// 线程启动

- (void)start;

阻塞线程:

 

// 线程休眠到某一时刻+ (void)sleepUntilDate:(NSDate *)date;// 线程休眠多久+ (void)sleepForTimeInterval:(NSTimeInterval)ti;

结束线程：

 

// 结束线程

+ (void)exit;

大家在看官方api的时候可能会有一个疑问，api里明明有cancel方法，为什么使用cancel方法不能结束线程？
当我们使用cancel方法时，只是改变了线程的状态标识，并不能结束线程，所以我们要配合isCancelled方法进行使用。具体实现如下：

 

- (void)touchesBegan:(NSSet<UITouch *> *)touches withEvent:(UIEvent *)event {

    // 创建线程

    [self createThread];

}

 

/**

 *  创建线程

 */

- (void)createThread {

    // 创建线程

    NSThread *thread = [[NSThread alloc] initWithTarget:self selector:@selector(threadMethod) object:nil];

    thread.name = @"i‘m a new thread";

    // 启动线程

    [thread start];

}

 

/**

 *  线程方法

 */

- (void)threadMethod {

    NSLog(@"thread is create -- the name is: \"%@\"", [NSThread currentThread].name);

    // 线程阻塞 -- 延迟到某一时刻 --- 这里的时刻是3秒以后

    [NSThread sleepUntilDate:[NSDate dateWithTimeIntervalSinceNow:3]];

    NSLog(@"sleep end");

    NSLog(@"sleep again");

    // 线程阻塞 -- 延迟多久 -- 这里延迟2秒

    [NSThread sleepForTimeInterval:2];

    NSLog(@"sleep again end");

 

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

        NSLog(@"thread working");

        if(30 == i) {

            NSLog(@"thread will dead");

            [[NSThread currentThread] cancel];

        }

        if([[NSThread currentThread] isCancelled]) {

            // 结束线程

//            [NSThread exit];

            return;

        }

    }

}

 

3. 线程间通信

线程间通信我们最常用的就是开启子线程进行耗时操作，操作完毕后回到主线程，进行数据赋值以及刷新主线程UI。在这里，用一个经典的图片下载demo进行简述。
首先我们先了解一下api给出的线程间通信的方法：

//与主线程通信

- (void)performSelectorOnMainThread:(SEL)aSelector withObject:(id)arg waitUntilDone:(BOOL)wait modes:(NSArray *)array;

- (void)performSelectorOnMainThread:(SEL)aSelector withObject:(id)arg waitUntilDone:(BOOL)wait;

  // equivalent to the first method with kCFRunLoopCommonModes

 

//与其他子线程通信

- (void)performSelector:(SEL)aSelector onThread:(NSThread *)thr withObject:(id)arg waitUntilDone:(BOOL)wait modes:(NSArray *)array NS_AVAILABLE(10_5, 2_0);

- (void)performSelector:(SEL)aSelector onThread:(NSThread *)thr withObject:(id)arg waitUntilDone:(BOOL)wait

以下是demo中的代码片段:

 

- (void)touchesBegan:(NSSet<UITouch *> *)touches withEvent:(UIEvent *)event {

    // 下载图片

    [self downloadImage];

}

 

/**

 *  下载图片

 */

- (void)downloadImage {

    // 创建线程下载图片

    [NSThread detachNewThreadSelector:@selector(downloadImageInThread) toTarget:self withObject:nil];

}

 

/**

 *  线程中下载图片操作

 */

- (void)downloadImageInThread {

    NSLog(@"come in sub thread -- %@", [NSThread currentThread]);

    // 获取图片url

    NSURL *url = [NSURL URLWithString:@"http://img.ycwb.com/news/attachement/jpg/site2/20110226/90fba60155890ed3082500.jpg"];

    // 计算耗时

    NSDate *begin = [NSDate date];

    // 使用CoreFoundation计算耗时 CFDate

    CFTimeInterval beginInCF = CFAbsoluteTimeGetCurrent();

    // 从url读取数据(下载图片) -- 耗时操作

    NSData *imageData = [NSData dataWithContentsOfURL:url];

    NSDate *end = [NSDate date];

    CFTimeInterval endInCF= CFAbsoluteTimeGetCurrent();

    // 计算时间差

    NSLog(@"time difference -- %f", [end timeIntervalSinceDate:begin]);

    NSLog(@"time difference inCF -- %f", endInCF - beginInCF);

    // 通过二进制data创建image

    UIImage *image = [UIImage imageWithData:imageData];

 

    // 回到主线程进行图片赋值和界面刷新

    [self performSelectorOnMainThread:@selector(backToMainThread:) withObject:image waitUntilDone:YES];

    // 这里也可以使用imageView的set方法进行操作

//    [self.imageView performSelectorOnMainThread:@selector(setImage:) withObject:image waitUntilDone:YES];

}

 

/**

 *  回到主线程的操作

 */

- (void)backToMainThread:(UIImage *)image {

    NSLog(@"back to main thread --- %@", [NSThread currentThread]);

    // 赋值图片到imageview

    self.imageView.image = image;

 

在demo中已经把注释写的比较清晰了，需要补充的有三点:

  1. performSelectorOnMainThread:withObject:waitUntilDone:方法这里是回到了主线程进行操作，同样也可以使用

[self performSelector:@selector(backToMainThread:) onThread:[NSThread mainThread] withObject:image waitUntilDone:YES];

  1. 回到主线程，或者进入其他线程进行操作。

  2. 在实际项目中我们可能会分析耗时操作所花费时间或者分析用户行为的时候要计算用户在当前页面所耗时间，所以在demo中加入了时间的两种计算方式，分别是CoreFoundation和Foundation中的。

// 计算耗时

 NSDate *begin = [NSDate date];

 // 使用CoreFoundation计算耗时 CFDate

 CFTimeInterval beginInCF = CFAbsoluteTimeGetCurrent();

 // 从url读取数据(下载图片) -- 耗时操作

 NSData *imageData = [NSData dataWithContentsOfURL:url];

 NSDate *end = [NSDate date];

 CFTimeInterval endInCF= CFAbsoluteTimeGetCurrent();

 // 计算时间差

 NSLog(@"time difference -- %f", [end timeIntervalSinceDate:begin]);

 NSLog(@"time difference inCF -- %f", endInCF - beginInCF);

3. 如果自己写的项目无法运行，可能是因为Xcode7 创建HTTP请求报错导致，具体解决方案请点击这里。

4. 线程安全

因为是多线程操作，所以会存在一定的安全隐患。原因是多线程会存在不同线程的资源共享，也就是说我们可能在同一时刻两个线程同时操作了某一个变量的值，但是线程的对变量的操作不同，导致变量的值出现误差。下面是一个存取钱的demo片段：

- (void)viewDidLoad {

    [super viewDidLoad];

    // Do any additional setup after loading the view, typically from a nib.

    // 初始化状态

    [self initStatus];

}

 

- (void)touchesBegan:(NSSet<UITouch *> *)touches withEvent:(UIEvent *)event {

    // 启动线程

    [self startThread];

}

 

/**

 *  初始化状态

 */

- (void)initStatus {

    // 设置存款

    self.depositMoney = 5000;

    // 创建存取钱线程

    self.saveThread = [[NSThread alloc] initWithTarget:self selector:@selector(saveAndDraw) object:nil];

    self.saveThread.name = @"save";

    self.drawThread = [[NSThread alloc] initWithTarget:self selector:@selector(saveAndDraw) object:nil];

    self.drawThread.name = @"draw";

}

 

/**

 *  开启线程

 */

- (void)startThread {

    // 开启存取钱线程

    [self.saveThread start];

    [self.drawThread start];

}

 

/**

 *  存取钱操作

 */

- (void)saveAndDraw {

    while(1) {

        if(self.depositMoney > 3000) {

            // 阻塞线程，模拟操作花费时间

            [NSThread sleepForTimeInterval:0.05];

            if([[NSThread currentThread].name isEqualToString:@"save"]) {

                self.depositMoney += 100;

            } else {

                self.depositMoney -= 100;

            }

            NSLog(@"currentThread: %@, depositMoney: %d", [NSThread currentThread].name, self.depositMoney);

        } else {

            NSLog(@"no money");

            return;

        }

    }

}

在上面的demo中我们发现，存取钱的线程是同时开启的，而存取钱的钱数相同，所以每一次存取操作结束后，存款值应该不会改变。大家可以运行demo进行查看结果。
所以需要在线程操作中加入锁：

/**

 *  存取钱操作

 */

- (void)saveAndDraw {

    while(1) {

        // 互斥锁

        @synchronized (self) {

            if(self.depositMoney > 3000) {

               // 阻塞线程，模拟操作花费时间

                [NSThread sleepForTimeInterval:0.05];

                if([[NSThread currentThread].name isEqualToString:@"save"]) {

                    self.depositMoney += 100;

                } else {

                    self.depositMoney -= 100;

                }

                NSLog(@"currentThread: %@, depositMoney: %d", [NSThread currentThread].name, self.depositMoney);

            } else {

                NSLog(@"no money");

                return;

            }

        }

    }

}

线程安全解决方案：

* 互斥锁

@synchronized 的作用是创建一个互斥锁，保证此时没有其它线程对锁住的对象进行修改。

* 互斥锁使用格式：

@synchronized (锁对象) { // 需要锁定的代码 }

* 互斥锁的优缺点：

优点: 防止多线程对共享资源进行抢夺造成的数据安全问题

缺点: 需要消耗大量cpu资源

 

注：NSThread头文件中的相关方法

//获取当前线程

 +(NSThread *)currentThread; 

//创建线程后自动启动线程

+ (void)detachNewThreadSelector:(SEL)selector toTarget:(id)target withObject:(id)argument;

//是否是多线程

+ (BOOL)isMultiThreaded;

//线程字典

- (NSMutableDictionary *)threadDictionary;

//线程休眠到什么时间

+ (void)sleepUntilDate:(NSDate *)date;

//线程休眠多久

+ (void)sleepForTimeInterval:(NSTimeInterval)ti;

//退出线程

+ (void)exit;

//线程优先级

+ (double)threadPriority;

+ (BOOL)setThreadPriority:(double)p;

- (double)threadPriority NS_AVAILABLE(10_6, 4_0);

- (void)setThreadPriority:(double)p NS_AVAILABLE(10_6, 4_0);

//调用栈返回地址

+ (NSArray *)callStackReturnAddresses NS_AVAILABLE(10_5, 2_0);

+ (NSArray *)callStackSymbols NS_AVAILABLE(10_6, 4_0);

//设置线程名字

- (void)setName:(NSString *)n NS_AVAILABLE(10_5, 2_0);

- (NSString *)name NS_AVAILABLE(10_5, 2_0);

//获取栈的大小

- (NSUInteger)stackSize NS_AVAILABLE(10_5, 2_0);

- (void)setStackSize:(NSUInteger)s NS_AVAILABLE(10_5, 2_0);

//是否是主线程

- (BOOL)isMainThread NS_AVAILABLE(10_5, 2_0);

+ (BOOL)isMainThread NS_AVAILABLE(10_5, 2_0); // reports whether current thread is main

+ (NSThread *)mainThread NS_AVAILABLE(10_5, 2_0);

//初始化方法

- (id)init NS_AVAILABLE(10_5, 2_0); // designated initializer

- (id)initWithTarget:(id)target selector:(SEL)selector object:(id)argument NS_AVAILABLE(10_5, 2_0);

//是否正在执行

- (BOOL)isExecuting NS_AVAILABLE(10_5, 2_0);

//是否执行完成

- (BOOL)isFinished NS_AVAILABLE(10_5, 2_0);

//是否取消线程

- (BOOL)isCancelled NS_AVAILABLE(10_5, 2_0);

- (void)cancel NS_AVAILABLE(10_5, 2_0);

//线程启动

- (void)start NS_AVAILABLE(10_5, 2_0);

- (void)main NS_AVAILABLE(10_5, 2_0); // thread body method

@end

//多线程通知

FOUNDATION_EXPORT NSString * const NSWillBecomeMultiThreadedNotification;

FOUNDATION_EXPORT NSString * const NSDidBecomeSingleThreadedNotification;

FOUNDATION_EXPORT NSString * const NSThreadWillExitNotification;

 

@interface NSObject (NSThreadPerformAdditions)

//与主线程通信

- (void)performSelectorOnMainThread:(SEL)aSelector withObject:(id)arg waitUntilDone:(BOOL)wait modes:(NSArray *)array;

- (void)performSelectorOnMainThread:(SEL)aSelector withObject:(id)arg waitUntilDone:(BOOL)wait;

  // equivalent to the first method with kCFRunLoopCommonModes

//与其他子线程通信

- (void)performSelector:(SEL)aSelector onThread:(NSThread *)thr withObject:(id)arg waitUntilDone:(BOOL)wait modes:(NSArray *)array NS_AVAILABLE(10_5, 2_0);

- (void)performSelector:(SEL)aSelector onThread:(NSThread *)thr withObject:(id)arg waitUntilDone:(BOOL)wait NS_AVAILABLE(10_5, 2_0);

  // equivalent to the first method with kCFRunLoopCommonModes

//隐式创建并启动线程

- (void)performSelectorInBackground:(SEL)aSelector withObject:(id)arg NS_AVAILABLE(10_5, 2_0);

 

由于多线程内容比较多，所以这里拆成两个部分。此文介绍PThread和NSThread，下篇文章将会跟大家一起讨论一下GCD和NSOperation的知识。希望本文章能对大家有所帮助。

以上是关于iOS—— 多线程之pthreadNSThread的主要内容，如果未能解决你的问题，请参考以下文章

多线程 - pthreadNSThread

iOS底层探索之多线程(十五)—@synchronized源码分析

iOS多线程之GCD小记

iOS底层探索之多线程(十四)—关于@synchronized锁你了解多少?

iOS底层探索之多线程(十三)—锁的种类你知多少?

iOS多线程开发之GCD（下篇）