userInteractive#

UI の更新など、即座にタスクが実行されてほしい場合に利用する。

userInitiated#

ボタンのタップなどで非同期に処理をする場合に利用する。優先度highが割り当てられる。

default#

デフォルトの優先度。

utility#

プログレスバーや、計算処理、ダウンロード処理などで使う。

background#

すぐには利用しないデータのプリフェッチなどで使う。

unspecified#

特筆すべき優先度がないことを示す。システム側で自動的に優先度が割り当てられる。

sleep を使う#

Swift には標準でsleepコマンドがあるのでそれを利用する。

import SwiftUI

struct ContentView: View {
    @State var dateList: [String] = []
    var body: some View {
        List {
            ForEach(dateList, id:\.self) { date in
                Text(date)
            }
        }
        Button(action: { runDispatchQueue() }, label: {
            Text("Run")
        })
    }

    private func runDispatchQueue() {
        for _ in 0 ..< 10 {
            dateList.append("\(Date().description) on \(Thread.current.isMainThread)")
            sleep(1)
        }
    }
}

ところがこのコードは想定通りの動作をしない。というのもrunDispatchQueueがメインスレッドで実行されてしまうからだ。

つまり、sleep(1)はメインスレッドを 1 秒間停止するという意味になり、それを 10 回繰り返すのでトータル 10 秒間メインスレッドが停止してしまう。

メインスレッドが停止するということは画面の再描画がされないのでフリーズしたような状態になってしまうことを意味する。更に「処理 ->1 秒停止」なので処理中はメインスレッドが動いているため画面の再描画がされそうな気もするのだが、実際にはされないことにも注意しよう。

Thread.sleep を使う#

ではsleepではなくThread.sleepを使ってみてはどうかということになるが、これも結局rundDispatchQueue()がメインスレッドで実行されているのでメインスレッドが止まってしまう。

private func runDispatchQueue() {
    dateList.removeAll(keepingCapacity: true)
    for _ in 0 ..< 10 {
        dateList.append("\(Date().description) on \(Thread.current.isMainThread)")
        Thread.sleep(forTimeInterval: 1)
    }
}

Serial + Sync#

syncを指定するとDispatchQueueのクロージャが全部終了してから呼び出し元に制御を返します。

import SwiftUI

struct ContentView: View {
    @State var dateList: [String] = []
    // 逐次処理
    let queue = DispatchQueue(label: "work.tkgstrator.dispatch_queue_serial")

    var body: some View {
        List {
            ForEach(dateList, id:\.self) { date in
                Text(date)
            }
        }
        Button(action: { runDispatchQueue() }, label: {
            Text("Run")
        })
    }

    private func runDispatchQueue() {
        dateList.removeAll(keepingCapacity: true)
        for loop in 0 ..< 10 {
            queue.sync {
                dateList.append("\(loop) -> \(Date().description) on \(Thread.current.isMainThread)")
                Thread.sleep(forTimeInterval: 1)
            }
        }
    }
}

よってこれは以下のように動作します。

• メインスレッドがrunDispatchQueueを実行
• グローバルスレッドがループを実行
  • その間メインスレッドはグローバルスレッドが完了するのを待つ
  • 待っている間は当然sleepしているとの同じ状態
• グローバルスレッドが制御を返す
• dateListが変化しているので画面の再描画が行われる

::: tip ナゼ？

DispatchQueueではグローバルスレッドを指定しているはずなのだが、何故かメインスレッドで実行される。

これに限らず、Syncを使うとメインスレッドで実行されてしまう。そういう宿命なのだろうか。

:::

しかも実行してみるとGlobal Queueとして実行しているはずなのに何故かメインスレッドで実行されています、謎です。

Serial + Async#

次にAsyncを使って実行してみます。

これはメインスレッドを止めずに裏で実行するような感じですので期待通りの結果が得られます。

private func runDispatchQueue() {
    dateList.removeAll(keepingCapacity: true)
    for loop in 0 ..< 10 {
        queue.async {
            dateList.append("\(loop) -> \(Date().description) on \(Thread.current.isMainThread)")
            Thread.sleep(forTimeInterval: 1)
        }
    }
}

つまり、ちゃんと 1 秒毎にデータが 1 つずつ増えていき、その順番も内容も間違っていないということです。

Sync + Main.Sync#

Sync内でMain.Asyncを動かすとどうなるのでしょうか。

これをするとdateList.append()を行うのとsleepをするスレッドが同じであるにも関わらず、先にすぐに処理が終わるdateList.append()を実行した後に 10 秒間のスリープ処理が入ります。

つまり、ボタンを押した瞬間にフリーズして全く同じデータ（ボタンを押した時刻）が 10 秒後に描画されます。

private func runDispatchQueue() {
    dateList.removeAll(keepingCapacity: true)
    for loop in 0 ..< 10 {
        queue.async {
            dateList.append("\(loop) -> \(Date().description) on \(Thread.current.isMainThread)")
            print("\(loop) -> \(Date().description) on \(Thread.current.isMainThread)")
            DispatchQueue.main.async {
                Thread.sleep(forTimeInterval: 1)
            }
        }
    }
}

Async + Main.Async#

次にAsync内でメインスレッドを動かしてみます。

すると、dateList.append()とsleepが別スレッドで実行されるため、ボタンを押して 1 秒後に画面が一気に再描画されます。つまり、データは全部同一の時刻が表示されるため、中身は正しくありません。

private func runDispatchQueue() {
    dateList.removeAll(keepingCapacity: true)
    for loop in 0 ..< 10 {
        queue.async {
            dateList.append("\(loop) -> \(Date().description) on \(Thread.current.isMainThread)")
            print("\(loop) -> \(Date().description) on \(Thread.current.isMainThread)")
            DispatchQueue.main.async {
                Thread.sleep(forTimeInterval: 1)
            }
        }
    }
}

まとめ#

スリープ処理をしたいのであればDispatchQueue.global.asyncを使おう。