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



#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運(yùn)行，同步加入BTask
 2.BTask加入到請求隊列中，可是沒有其他空余線程（ATask線程在 等待BTask）,BTask等待空余線程，
 3.死鎖發(fā)生
 
 */
- (void)testSerialQueueSync {
  dispatch_sync(_serialQueue,^{
    [self fooA];
    dispatch_sync(_serialQueue,^{
       [self fooB];
    });
    [self fooA];
  });
}

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

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

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

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

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

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

@end