Skip to content

Commit 2a7f01e

Browse files
authored
Merge pull request #62 from narumij/work/55
Incremental AdoptionからDispatchの記述を削除する
2 parents c455339 + 1fc6130 commit 2a7f01e

File tree

1 file changed

+0
-82
lines changed

1 file changed

+0
-82
lines changed

Guide.docc/IncrementalAdoption.md

Lines changed: 0 additions & 82 deletions
Original file line numberDiff line numberDiff line change
@@ -415,85 +415,3 @@ final class MyJetPack: NSJetPack {
415415
```
416416

417417
こうすることで、Swiftは、メソッドがメインアクターの隔離を必要とするという誤った仮定を確認しないようになります。
418-
419-
## Dispatch
420-
421-
Dispatchや他の並行処理ライブラリで使い慣れているだろう一部のパターンは、Swiftの構造化並行処理モデルの世界に適合させるために、形を変える必要があるかもしれません。
422-
423-
### タスクグループを用いた並行処理の制限
424-
425-
処理するべき大量の作業リストを抱えていることもあるかもしれません。
426-
427-
次のように"すべて"の作業項目をタスクグループに追加することは、可能といえば可能です:
428-
429-
```swift
430-
// WARNING: 無駄が多い処理かも -- おそらく、このコードは数千のタスクを同時並行的に作成する(?!)
431-
432-
let lotsOfWork: [Work] = ...
433-
await withTaskGroup(of: Something.self) { group in
434-
for work in lotsOfWork {
435-
// WARNING: もしもこれが数千もの項目なら、
436-
// 同時に実行するタスクの数(システムのコア数に依存)とデフォルトのグローバルエグゼキュータの設定にグローバルな制限があるため、
437-
// かなり後になってからでないと実行されないタスクが多数作成される可能性がある。
438-
group.addTask {
439-
await work.work()
440-
}
441-
}
442-
443-
for await result in group {
444-
process(result) // 必要に応じて、結果を何らかの方法で処理する
445-
}
446-
}
447-
```
448-
449-
何百または何千もの項目を扱うつもりなら、それらをすべて一気にタスクグループに追加するのは非効率的かもしれません。
450-
メモリ量はさほど大きくない一方で、タスクを(`addTask` で)作成するにはタスクに中断と実行のためのメモリをいくらか割り当てる必要があります。
451-
ただちに実行されずエグゼキュータが実行するまで待機するだけのタスクを何千個も作成した場合に大きな影響を及ぼす可能性があります。
452-
453-
このような状況に直面した場合、次のように、タスクグループに同時に追加されるタスクの数を手動で調整するとよい場合があります:
454-
455-
```swift
456-
let lotsOfWork: [Work] = ...
457-
let maxConcurrentWorkTasks = min(lotsOfWork.count, 10)
458-
assert(maxConcurrentWorkTasks > 0)
459-
460-
await withTaskGroup(of: Something.self) { group in
461-
var submittedWork = 0
462-
for _ in 0..<maxConcurrentWorkTasks {
463-
group.addTask { // または 'addTaskUnlessCancelled'
464-
await lotsOfWork[submittedWork].work()
465-
}
466-
submittedWork += 1
467-
}
468-
469-
for await result in group {
470-
process(result) // 必要に応じて、結果を何らかの方法で処理する
471-
472-
// 結果が返ってくる度に、実行すべき追加の作業があるかどうかを確認する
473-
if submittedWork < lotsOfWork.count,
474-
let remainingWorkItem = lotsOfWork[submittedWork] {
475-
group.addTask { // または 'addTaskUnlessCancelled'
476-
await remainingWorkItem.work()
477-
}
478-
submittedWork += 1
479-
}
480-
}
481-
}
482-
```
483-
484-
「作業」タスクが長時間実行される同期コードを含んでいるなら、そのタスクを自ら中断し他のタスクが実行できるようにするほうが合理的なこともあります:
485-
486-
```swift
487-
struct Work {
488-
let dependency: Dependency
489-
func work() async {
490-
await dependency.fetch()
491-
// 長時間実行される同期コードの一部を実行する
492-
await Task.yield() // 明示的に中断ポイントを入れる
493-
// 長時間実行される同期実行を続ける
494-
}
495-
}
496-
```
497-
498-
明示的な中断ポイントの導入は、Swiftがこのタスクの進捗とプログラム内の他のタスクの作業の進捗のバランスをとるのに役立ちます。
499-
しかし、システムのなかでこのタスクが最も優先順位が高い場合、エグゼキュータはただちに同じタスクの実行を再開します。そのため、明示的な中断ポイントで必ずしも資源飢餓を避けられるわけではありません。

0 commit comments

Comments
 (0)