IOS開發-多線程隊列測試代碼

//
// 單線程和多線程并發隊列測試(同步和異步)
//
// 基礎原理：
// 1)隊列：
//  1.1 dispatch_queue_t 是一個隊列,一個FIFO的消費隊列
//  1.2 消費者：隊列配置的運行線程
//  1.3 被消費對象: 添加到隊列中的運行任務（block等）
//  1.4 運行任務：將任務放到隊列中，等待消費者消費
// 2)同步，異步  （對于任務） （此處的運行指將任務發入到請求隊列中）
//  2.1 同步：A任務在運行時，插入B任務，A任務等待B任務運行完才能運行
//  2.2 異步: A任務在運行時，插入B任務,A任務不等待并且繼續運行，B任務也運行
// 假設：
// ATask: 運行fooA的Block
// BTask: 運行fooB的Block
//
//
// 總結：
// 不管單線程或多線程，同步或異步，一定要聯系請求隊列考慮



#import "TestQueueSi.h"

@interface TestQueueSi ()

@property (strong,nonatomic) dispatch_queue_t serialQueue;
@property (strong,nonatomic) dispatch_queue_t concurrentQueue;

@end

@implementation TestQueueSi


- (instancetype)init {
  self = [super init];
  if(self) {
    _serialQueue = dispatch_queue_create("chenhh.serialQueue", DISPATCH_QUEUE_SERIAL);
    _concurrentQueue = dispatch_queue_create("chenhh.concurrentQueue", DISPATCH_QUEUE_CONCURRENT);

  }
  return self;
}

/**
 QUEUE_SERIAL(單線程) 同步
 死鎖崩潰
 
 1.ATask運行，同步加入BTask
 2.BTask加入到請求隊列中，可是沒有其他空余線程（ATask線程在 等待BTask）,BTask等待空余線程，
 3.死鎖發生
 
 */
- (void)testSerialQueueSync {
  dispatch_sync(_serialQueue,^{
    [self fooA];
    dispatch_sync(_serialQueue,^{
       [self fooB];
    });
    [self fooA];
  });
}

/**
 QUEUE_CONCURRENT(多線程) 同步
 正常運行

 1.ATask運行，同步加入BTask，Atask線程等待
 2.BTask加入到請求隊列中，有其他空余線程（ATask線程在等待BTask）,BTask運行
 3.BTask運行結束，ATask停止等待，繼續運行
 
 */
- (void)testConcurrentQueueSync {
  dispatch_sync(_concurrentQueue,^{
    [self fooA];
    NSLog(@"first");
    
    // 同步 需要等待運行結果
    dispatch_sync(_concurrentQueue,^{
      [self fooB];
    });
    
    // 等待同步代碼完成，再運行
    [self fooA];
  });
}

/*
 QUEUE_SERIAL(單線程) 異步
 正常
 
 
 1.ATask運行，異步加入BTask，Atask線程繼續運行不等待
 2.BTask加入到請求隊列中，沒有其他空余線程（ATask線程在正常運行）,BTask等待空余
 3.ATask運行完成，線程空出，BTask運行
 
 */
- (void)testSerialQueueAsync {
  dispatch_async(_serialQueue,^{
    [self fooA];
    dispatch_async(_serialQueue,^{
      [self fooB];
    });
     [self fooA];
  });
}

/**
 QUEUE_CONCURRENT(多線程) 異步
 正常運行
 
 1.ATask運行，同步加入BTask，Atask線程繼續運行不等待
 2.BTask加入到請求隊列中，有其他空余線程（ATask等線程在正常運行）,BTask運行（ABTask同時運行）
 
 */
- (void)testConcurrentQueueAsync {
  dispatch_async(_concurrentQueue,^{
    [self fooA];
    // 同步 需要等待運行結果
    dispatch_async(_concurrentQueue,^{
      [self fooB];
    });
    
    // 等待同步代碼完成，再運行
    [self fooA];
  });
}

- (void)fooA {
  NSLog(@" ************ fooA ************ ");
}

- (void)fooB {
  NSLog(@" ************ fooB ************ ");
}

@end