iOS开发Swift

Swift 多线程的几个例子

  • 添加任务到队列的方法 
DispatchQueue.global(qos: .default).async {
    //处理耗时操作的代码块...
    print("do work")
     
    //操作完成,调用主线程来刷新界面
    DispatchQueue.main.async {
        print("main refresh")
    }
}

//添加同步代码块到global队列
//不会造成死锁,但会一直等待代码块执行完毕
DispatchQueue.global(qos: .default).sync {
    print("sync1")
}
print("end1")


//添加同步代码块到main队列
//会引起死锁
//因为在主线程里面添加一个任务,因为是同步,所以要等添加的任务执行完毕后才能继续走下去。但是新添加的任务排在
//队列的末尾,要执行完成必须等前面的任务执行完成,由此又回到了第一步,程序卡死
DispatchQueue.main.sync {
    print("sync2")
}
print("end2")
  • 只执行一次
//往dispatch_get_global_queue队列中添加代码块,只执行一次
var predicate:dispatch_once_t = 0
dispatch_once(&predicate, { () -> Void in
    //只执行一次,可用于创建单例
    println("work")
})
  • asyncAfter 延迟调用
//延时2秒执行
DispatchQueue.global(qos: .default).asyncAfter(deadline: DispatchTime.now() + 2.0) {
    print("after!")
}
  • 信号,信号量
DispatchSemaphore(value: ):用于创建信号量,可以指定初始化信号量计数值,这里我们默认1.
semaphore.wait():会判断信号量,如果为1,则往下执行。如果是0,则等待。
semaphore.signal():代表运行结束,信号量加1,有等待的任务这个时候才会继续执行

//获取系统存在的全局队列
let queue = DispatchQueue.global(qos: .default)
 
//当并行执行的任务更新数据时,会产生数据不一样的情况
for i in 1...10 {
    queue.async {
        print("\(i)")
    }
}
 
//使用信号量保证正确性
//创建一个初始计数值为1的信号
let semaphore = DispatchSemaphore(value: 1)
for i in 1...10 {
    queue.async {
        //永久等待,直到Dispatch Semaphore的计数值 >= 1
        semaphore.wait()
        print("\(i)")
        //发信号,使原来的信号计数值+1
        semaphore.signal()
    }
}
  • 多个任务全部结束后做一个全部结束的处理
async(group:):用来监视一组block对象的完成,你可以同步或异步地监视
notify():用来汇总结果,所有任务结束汇总,不阻塞当前线程
wait():等待直到所有任务执行结束,中途不能取消,阻塞当前线程

//获取系统存在的全局队列
let queue = DispatchQueue.global(qos: .default)
//定义一个group
let group = DispatchGroup()
//并发任务,顺序执行
queue.async(group: group) {
    sleep(2)
    print("block1")
}
queue.async(group: group) {
    print("block2")
}
queue.async(group: group) {
    print("block3")
}
 
//1,所有任务执行结束汇总,不阻塞当前线程
group.notify(queue: .global(), execute: {
    print("group done")
})
 
//2,永久等待,直到所有任务执行结束,中途不能取消,阻塞当前线程
group.wait()
print("任务全部执行完成")
  • 暂停或者继续队列
这两个函数是异步的,而且只在不同的blocks之间生效,对已经正在执行的任务没有影响。
suspend()后,追加到Dispatch Queue中尚未执行的任务在此之后停止执行。
而resume()则使得这些任务能够继续执行。

//创建并行队列
let conQueue = DispatchQueue(label: "concurrentQueue1", attributes: .concurrent)
//暂停一个队列
conQueue.suspend()
//继续队列
conQueue.resume()
  • 运行在主线程的Main Dispatch Queue
正如名称中的Main一样,这是在主线程里执行的队列。因为主线程只有一个,所有这自然是串行队列。一起跟UI有关的操作必须放在主线程中执行。
let mainQueue = DispatchQueue.main