💬

【翻訳】Concurrency in Swift (Grand Central Dispatch Part 2)

2023/07/18に公開

Swift

concurrency

非同期処理

tech

このパートでは、以下のトピックを取り上げます。

ディスパッチ・グループとは
ディスパッチ・グループの実装方法待機と通知ストラテジーを使って
ディスパッチ・バリアとは
Dispatch Barrierを使ってリーダとライタの問題を解決する方法

前回の続きです。GCDの基本がわかっていれば、この続きは可能です。

ディスパッチ・グループ

ディスパッチ・グループは、1つ以上のタスクの実行が終了するまでスレッドをブロックする方法です。
この動作は、指定したタスクがすべて完了するまで処理を進められないような場所で使うことができます。
例えば、あるデータを計算するために複数のタスクをディスパッチした後、
グループを使用してそれらのタスクを待機させ、タスクが終了したらその結果を処理するような場合です。
DispatchGroupは作業の集約的な同期を可能にする

図1に示すように、2つのタスクを同時に実行し、ディスパッチ・グループのwait関数を使用して、
これらのタスクの両方が実行されるまでスレッドをブロックして終了を待ちます。
以下のコードでは、以下のステップを実行しています。

waitを使用したディスパッチグループ

"com.company.app.queue "というラベルのカスタムキューを作成
ディスパッチ・グループを作成
group.enter()を使用して、ブロックがグループに入ったことを手動で示す。
注意: この関数の呼び出しは、dispatch_group_leave()とバランスをとる必要があります。
さもないとアプリケーションがクラッシュします。
タスク1がqueue.asyncを通して実行され、即座に戻り、GCDがこのタスクを同時に実行し始めます。
group.enter()を使って、ブロックがグループに入ったことを手動で示します。
タスク2がqueue.asyncを通して実行され、即座に戻り、GCDがこのタスクの同時実行を開始します。
group.wait()（上記のすべてのタスクが終了するまで、ここにあるスレッドをブロックする
（メインスレッドでこの関数を使用しないように）メインスレッドでこのメソッドを呼び出したので、
メインスレッドをブロックします。

図1

図2に示すように、メイン・キューの代わりに並行キューでwait()メソッドを使用しているため、
バックグラウンド・スレッドがブロックされています。

図2

notifyを使ったディスパッチ・グループ

非同期でキューにディスパッチし、waitを使って作業をブロックするのは、
前の例でメイン・スレッドをブロックしているのを見ればわかるように、良いことではありません。
幸い、もっと良い方法があります。
DispatchGroupは、グループのすべてのタスクが完了したときに通知してくれます。
図3に示すように、両方のタスクが完了すると、Dispatch Groupはnotifyメソッドを呼び出します。

図3

図3.1と図3.2に示すように、notifyを使ったが、タスク1の後に "#3 finished "と表示され、
タスク3は終了したが、タスク2を待たなかった。タスク2をグループに追加しなかったので、
このタスクの完了を待たなかったためです。

グループを使用すると、一連のタスクを集約し、グループ上の動作を同期させることができます。
複数のワークアイテムをグループにアタッチし、それらを同じキューまたは異なるキューで
非同期に実行するようにスケジュールします。すべてのワークアイテムの実行が終了すると、
グループは完了ハンドルを実行します。

図3.1

図3.2

図3.3に示すように、enter()とleave()を追加したため、
グループは3つのタスクがすべて終了するまで待機します。

図3.3

Dispatchグループはqueueをパラメータとして取り、どのqueueで完了ブロックを実行するかを決定します。
図3.4に示すように、Dispatch.main() を指定すると、
メインスレッドに "#3 finished" と表示されます。

図3.4

ディスパッチ・バリア

ディスパッチバリアは、同時実行キューを扱う際にシリアル形式のボトルネックとして動作する関数群です。
DispatchWorkItem(task )をディスパッチキューに投入する際、その特定の時間、
指定されたキューで実行される唯一のアイテムであるべきことを示すフラグを設定することができます。
これは、ディスパッチバリアタスクの前にキューに投入されたすべてのアイテムが、
バリアタスクの実行を開始する前に完了しなければならないことを意味します。

図4に示すように、我々は以下のステップを実行しました。

カスタム並行ディスパッチ・キューを作成
キューに1つ目と2つ目のタスクを非同期で追加しました。理解できない場合はパート1を参照。
この時点で2つのタスクが並行キューに追加され、両方が同時に実行されています。次に、3番目のタスクを
ディスパッチバリアとして追加すると、前のタスクの両方がその実行を完了するまで、あるいは
完了しない限り、そのタスクは開始されず、開始されると、バリアタスクがシリアルに実行されます
（つまり、GCDは、そのタスクを完了するまで、このキュー上のこのタスクのみを実行する）。
最後に、バリアタスクが完了するまで実行されない4つのタスクを追加しました。

図4