//
//  ViewController.swift
//  并發(fā)
//
//  Created by houjianan on 2017/2/27.
//  Copyright ? 2017年 houjianan. All rights reserved.
//

import UIKit

class ViewController: UIViewController {

    override func viewDidLoad() {
        super.viewDidLoad()
        
        // 信號(hào)量和group
        // 各組執(zhí)行完才會(huì)執(zhí)行notify
        // 使用信號(hào)量 當(dāng)異步延遲執(zhí)行完才執(zhí)行notify
        // 如果沒有信號(hào)量控制 6的打印就是正常延遲3秒后執(zhí)行
        let queue = DispatchQueue.global(qos: .default)
        let group = DispatchGroup()
        let sem = DispatchSemaphore(value: 0)
        queue.async(group: group, execute: {
            print(1)
            queue.asyncAfter(deadline: DispatchTime.now() + Double(Int64(3 * 1000 * 1000000)) / Double(NSEC_PER_SEC), execute: {
                sem.signal()
                print(6)
            })
            sem.wait()
        })
        queue.async(group: group, execute: {
            print(2)
        })
        queue.async(group: group, execute: {
            print(3)
        })
        group.notify(queue: queue, execute: {
            print(5)
        })

        // group的enter()和leave()使用
        // 異步延遲方法都執(zhí)行完執(zhí)行notify
        let queue = DispatchQueue.global(qos: .default)
        let group = DispatchGroup()
        group.enter()
        queue.async(group: group, execute: {
            print(1)
            queue.asyncAfter(deadline: DispatchTime.now() + Double(Int64(3 * 1000 * 1000000)) / Double(NSEC_PER_SEC), execute: {
                print(6)
                group.leave()
            })
        })
        group.enter()
        queue.async(group: group, execute: {
            queue.asyncAfter(deadline: DispatchTime.now() + Double(Int64(3 * 1000 * 1000000)) / Double(NSEC_PER_SEC), execute: {
                print(2)
                group.leave()
            })
        })
        group.enter()
        queue.async(group: group, execute: {
            queue.asyncAfter(deadline: DispatchTime.now() + Double(Int64(3 * 1000 * 1000000)) / Double(NSEC_PER_SEC), execute: {
                print(3)
                group.leave()
            })
        })
        group.notify(queue: queue, execute: {
            print(4)
        })

        // group和信號(hào)量控制異步順序執(zhí)行
        let queue = DispatchQueue.global(qos: .default)
        let group = DispatchGroup()
        let sem = DispatchSemaphore(value: 0)
        queue.async(group: group, execute: {
            queue.asyncAfter(deadline: DispatchTime.now() + Double(Int64(3 * 1000 * 1000000)) / Double(NSEC_PER_SEC), execute: {
                sem.signal()
                print(1)
                sem.wait()
            })
        })
        queue.async(group: group, execute: {
            queue.asyncAfter(deadline: DispatchTime.now() + Double(Int64(3 * 1000 * 1000000)) / Double(NSEC_PER_SEC), execute: {
            sem.signal()
                print(2)
                sem.wait()
            })
            
        })
        queue.async(group: group, execute: {
            queue.asyncAfter(deadline: DispatchTime.now() + Double(Int64(3 * 1000 * 1000000)) / Double(NSEC_PER_SEC), execute: {
                sem.signal()
                print(3)
                sem.wait()
            })
        })
        group.notify(queue: queue, execute: {
            sem.signal()
            print(7)
            sem.wait()
        })

        // 標(biāo)記barrier的線程不執(zhí)行完 后面的不會(huì)執(zhí)行
        let dataQueue = DispatchQueue(label: "data", attributes: .concurrent)
        let write = DispatchWorkItem(flags: .barrier) {
            dataQueue.asyncAfter(deadline: DispatchTime.now() + Double(Int64(3 * 1000 * 1000000)) / Double(NSEC_PER_SEC), execute: {
                print(2.1)
            })
            print(2)
            Thread.sleep(forTimeInterval: 5)
        }
        
        dataQueue.async {
            print(1)
        }
        
        dataQueue.async(execute: write)
        
        dataQueue.async {
            print(3)
        }
    }
}