非同期のI/Oの実装(NetFramework)

using System;
using System.Collections;
using System.Threading;

public class MyApp {
	private static Queue que = Queue.Synchronized(new Queue());

	public static void Main() {
		Thread work = new Thread(new ThreadStart(Worker));

		// ワーカーの完了を待たない
		work.IsBackground = true;
		// スレッド開始
		work.Start();

		for (int i = 0; i < 100; ++i) {
			// 書き込み内容をキューへ追加
			string data = "No." + i.ToString();
			que.Enqueue(data);
			// テストのためのダミー（不要）
			Thread.Sleep(10);
		}

		// キューの作業終了を待つ
		while (que.Count > 0)
			Thread.Sleep(0);
	}

	// 作業スレッド
	public static void Worker() {
		while (true) {
			// キューにデータがあったら書き込む
			while (que.Count > 0) {
				string s = (string)que.Dequeue();
				Console.WriteLine(s);
			}
			// テストのためのダミー（不要）
			Thread.Sleep(500);
		}
	}
}