上級プロフェッショナル向け：VB.NETにおけるYieldキーワードを用いたイテレータの実装：大規模データをメモリ効率よく遅延評価するカスタム列挙の極意
こんにちは。大規模な業務システムや自動化ツールのアーキテクチャ設計を担当している。
日々の開発現場で、こんな悪夢に直面したことはないだろうか。
「数百万件の受発注データやログファイルをCSVやDBから一括読み込みしたら、`OutOfMemoryException`（メモリ不足例外）でサーバーが沈黙した」
「`.ToList()` や `.ToArray()` を思考停止で乱用し、CPUキャッシュ効率をドブに捨てている」
素人が書くコードは、目の前のデータをすべてメモリにロードしようとする。しかし、プロフェッショナルは違う。データは「必要な瞬間に、必要な分だけ」流し込むべきだ。
今回は、VB.NETの隠れた（だが極めて強力な）武器である `Iterator` と `Yield` キーワードを駆使し、メモリフットプリントを極限まで削ぎ落とした遅延評価（Deferred Execution）とストリーミング処理の極意を伝授する。
—
なぜ「一括読み込み」は悪なのか？（アーキテクチャの視点）
何十万行もあるCSVファイルや、巨大なデータベースクエリの結果を処理するとき、以下のようなコードを書く人間は即座にコードレビューで差し戻すべきだ。
.net
‘ 【アンチパターン】メモリを大量消費する最悪の例
Dim allRows As List(Of MyDataRecord) = LoadAllDataFromDatabase() ‘ 数百万件！
For Each row As var In allRows
If row.IsValid Then
Process(row)
End If
Next
このアプローチの何が問題か。
1. メモリの爆発（Memory Bloat）： GC（ガベージコレクション）の世代別ヒープを圧迫し、大規模なLOH（Large Object Heap）の断片化を引き起こす。
2. レイテンシの悪化（Time to First Result）： 最初の1件を処理するまでに、全データの読み込みとオブジェクト化が完了するのを待たされる。
これを解決するのが、.NETのイテレータパターンと `Yield` による遅延評価である。
—
Yieldキーワードの正体とライフサイクル
`Yield` は、コンパイラに対して「裏側で強力なステートマシン（状態機械）クラスを自動生成しろ」と命令するシンタックスシュガーだ。
VB.NETで `Iterator Function` を定義すると、コンパイラは `IEnumerable(Of T)` や `IEnumerator(Of T)` を実装した隠しクラスを裏で構築する。
`Yield` に到達するたびに制御権が呼び出し元に返還（Suspend）され、次の要素が要求されたときに、前回中断した行から実行が再開（Resume）される。
つまり、データを一度にメモリへ展開せず、データストリームのパイプラインを流れる水のように1件ずつ処理できるのだ。
—
【実務コード】メモリ効率を極限まで高めるストリーミング処理の実装
百聞は一見にしかず。実務でそのまま使える、巨大CSVファイルを1行ずつ遅延評価しながらフィルタリング・変換して処理する堅牢なプロダクションコードを示す。
.net
Imports System.IO
Imports System.Collections.Generic
Namespace Enterprise.DataProcessing
‘ データ構造体
Public Class TransactionRecord
public Property TransactionId As Long
public Property Timestamp As DateTime
public Property Amount As Decimal
public Property StoreCode As String
End Class
Public Module StreamingProcessor
”’
”’
”’ 対象のファイルパス
”’
Public Iterator Function StreamCsvData(filePath As String) As IEnumerable(Of TransactionRecord)
‘ Usingステートメントにより、イテレーション終了時（または途中でBreakした時）に
‘ 確実かつ安全にファイルストリームのリソースを解放する
Using fs As New FileStream(filePath, FileMode.Open, FileAccess.Read, FileShare.ReadWrite),
sr As New StreamReader(fs, System.Text.Encoding.UTF8)
‘ ヘッダー行をスキップ
Dim header As String = sr.ReadLine()
If header Is Nothing Then Exit Function
Dim lineCount As Long = 0
‘ 1行ずつ読み込む（全データを一度にメモリに乗せない）
While Not sr.EndOfStream
Dim line As String = sr.ReadLine()
lineCount += 1
If String.IsNullOrWhiteSpace(line) Then Continue While
‘ パフォーマンス考慮の簡易パース
Dim fields As String() = line.Split(“,”c)
If fields.Length >= 4 Then
Dim record As New TransactionRecord() With {
.TransactionId = CLng(fields(0)),
.Timestamp = CDate(fields(1)),
.CDec(fields(2)),
.StoreCode = fields(3).Trim()
}
‘ ★ここで Yield する！
‘ 呼び出し元に1件だけデータを渡し、次の要求が来るまでここで実行が一時停止する。
Yield record
End If
End While
End Using
End Function
”’
”’
Public Sub ExecutePipeline()
Dim targetFile As String = “C:\Data\HugeTransactions.csv”
‘ 1. イテレータの呼び出し（この時点ではファイルは一切読み込まれていない！）
Dim rawStream = StreamCsvData(targetFile)
‘ 2. LINQの遅延評価と組み合わせる（フィルタリング）
‘ ここでもデータは評価されず、クエリの「設計図」だけが構築される
Dim filteredStream = rawStream.Where(Function(r) r.Amount > 10000D AndAlso r.StoreCode = “TK01″)
‘ 3. 実際にループを回した瞬間から、1件ずつデータが流れて処理される
Dim processedCount As Long = 0
For Each record In filteredStream
‘ 必要な分だけメモリを消費し、処理が終わればGCの餌食になるためメモリが枯渇しない
Console.WriteLine($”Processing ID: {record.TransactionId}, Amount: {record.Amount}”)
processedCount += 1
‘ 例：大規模データであっても上位N件で打ち切る場合、ここでExit Forすれば
‘ StreamReaderのファイル読み込みも即座に中断され、無駄なI/Oが発生しない
If processedCount >= 1000 Then Exit For
Next
Console.WriteLine($”処理完了。総処理件数: {processedCount}”)
End Sub
End Module
End Namespace
—
プロが押さえるべき設計上の注意点と罠
`Iterator` と `Yield` は諸刃の剣だ。アーキテクトとして、以下の罠を確実に回避しなければならない。
1. 例外のスロータイミングのズレ（Deferred Exception）
遅延評価の最大の罠は、「コードを書いた場所」と「例外が発生する場所」が乖離することだ。
上記の `StreamCsvData` において、存在しないファイルパスを指定した場合でも、`StreamCsvData()` を呼び出した瞬間には例外は発生しない。`For Each` で最初の要素を要求（`MoveNext` が実行）された瞬間に `FileNotFoundException` が飛ぶ。
対策: 引数の検証（ガード節）だけは、イテレータの外側のラッパーメソッドで行うか、イテレータ関数の先頭で即座に評価すること。
.net
Public Iterator Function SafeStream(filePath As String) As IEnumerable(Of String)
‘ ガード節は即時評価させるため、別メソッドに切り出すかイテレータの構造を工夫する
If Not File.Exists(filePath) Then
Throw New FileNotFoundException(“指定されたファイルが存在しません。”, filePath)
End If
‘ 以降に Yield を記述
‘…
End Function
2. マルチスレッド環境とスレッドセーフティ
イテレータの列挙子（IEnumerator）は本質的にスレッドセーフではない。複数のスレッドから同時にひとつの `IEnumerator` の `MoveNext()` を叩いてはならない。並列処理を行いたい場合は、PLINQ（Parallel LINQ）の `.AsParallel()` や、タスクベースの非同期ストリーム（`IAsyncEnumerable(Of T)` / `.NET Core 3.0以降`）への移行を検討せよ。
3. リソースの確実な解放
`Using` ブロック内で `Yield` を使う場合、VB.NETのコンパイラは `Dispose` メソッドが呼び出されたとき（イテレーションが途中で破棄されたり、`Exit For` で抜けたとき）に、自動的にストリーム等のリソースをクリーンアップするコードを生成してくれる。非常にエレガントだが、例外発生時の挙動を含め、ファイルロックが意図せず残らないか `Using` のスコープ設計には細心の注意を払うこと。
—
まとめ
業務自動化や大規模データ処理において、「メモリを効率よく使う」ことはプログラマーの嗜みではなく、システムを生存させるための必須要件だ。
- 巨大なコレクションを安易に `List(Of T)` に詰め替えない。
- `Iterator` と `Yield` を用いて、データを「川の流れ（ストリーム）」のように扱う。
- 遅延評価の特性を理解し、無駄なCPUサイクルとメモリ消費を極限まで排除する。
この知見をあなたのプロジェクトに導入すれば、メモリ不足のエラーアラートに夜中たたき起こされる悪夢から解放されるはずだ。
プロフェッショナルたるもの、リソースを支配するコードを書け。
