[C#] await using構文を使ってオブジェクトを非同期的に破棄する

await using (var resource = new Resource())
{
    // リソースを使用する処理
}

public class Resource : IAsyncDisposable
{
    public async ValueTask DisposeAsync()
    {
        // 非同期的にリソースを解放する処理
        await Task.Delay(1000); // 例: 1秒待機
        Console.WriteLine("リソースが解放されました。");
    }
}

public async Task UseResourceAsync()
{
    await using (var resource = new Resource())
    {
        // リソースを使用する処理
        Console.WriteLine("リソースを使用中...");
        await Task.Delay(500); // 例: 0.5秒待機
    }
}

public async Task UseResourceWithExceptionAsync()
{
    await using (var resource = new Resource())
    {
        // 例外を発生させる処理
        throw new Exception("エラーが発生しました。");
    }
}

public async Task ReadFileAsync(string filePath)
{
    await using (var fileStream = new FileStream(filePath, FileMode.Open, FileAccess.Read, FileShare.None, 4096, FileOptions.Asynchronous))
    {
        byte[] buffer = new byte[1024];
        int bytesRead = await fileStream.ReadAsync(buffer, 0, buffer.Length);
        Console.WriteLine($"読み込んだバイト数: {bytesRead}");
    }
}

public async Task QueryDatabaseAsync(string connectionString)
{
    await using (var connection = new SqlConnection(connectionString))
    {
        await connection.OpenAsync();
        var command = new SqlCommand("SELECT * FROM Users", connection);
        await using (var reader = await command.ExecuteReaderAsync())
        {
            while (await reader.ReadAsync())
            {
                Console.WriteLine($"ユーザー名: {reader["UserName"]}");
            }
        }
    }
}

public async Task ConnectToServerAsync(string server, int port)
{
    await using (var client = new TcpClient())
    {
        await client.ConnectAsync(server, port);
        Console.WriteLine("サーバーに接続しました。");
        // ここでデータの送受信処理を行うことができます。
    }
}

public class CustomResource : IAsyncDisposable
{
    public async ValueTask DisposeAsync()
    {
        // 非同期的にリソースを解放する処理
        await Task.Delay(1000); // 例: 1秒待機
        Console.WriteLine("カスタムリソースが解放されました。");
    }
}
public async Task UseCustomResourceAsync()
{
    await using (var resource = new CustomResource())
    {
        Console.WriteLine("カスタムリソースを使用中...");
        await Task.Delay(500); // 例: 0.5秒待機
    }
}

public async Task ReadMultipleFilesAsync(string filePath1, string filePath2)
{
    await using (var fileStream1 = new FileStream(filePath1, FileMode.Open, FileAccess.Read, FileShare.None, 4096, FileOptions.Asynchronous))
    await using (var fileStream2 = new FileStream(filePath2, FileMode.Open, FileAccess.Read, FileShare.None, 4096, FileOptions.Asynchronous))
    {
        byte[] buffer1 = new byte[1024];
        byte[] buffer2 = new byte[1024];
        
        int bytesRead1 = await fileStream1.ReadAsync(buffer1, 0, buffer1.Length);
        int bytesRead2 = await fileStream2.ReadAsync(buffer2, 0, buffer2.Length);
        
        Console.WriteLine($"ファイル1の読み込んだバイト数: {bytesRead1}");
        Console.WriteLine($"ファイル2の読み込んだバイト数: {bytesRead2}");
    }
}

public async Task OptimizePerformanceAsync()
{
    var tasks = new List<Task>();
    for (int i = 0; i < 5; i++)
    {
        tasks.Add(Task.Run(async () =>
        {
            await using (var resource = new CustomResource())
            {
                Console.WriteLine($"リソース {i} を使用中...");
                await Task.Delay(1000); // 例: 1秒待機
            }
        }));
    }
    await Task.WhenAll(tasks);
}

public async Task UseResourceWithErrorHandlingAsync()
{
    await using (var resource = new CustomResource())
    {
        try
        {
            // 例外を発生させる処理
            throw new Exception("エラーが発生しました。");
        }
        catch (Exception ex)
        {
            Console.WriteLine($"例外が発生しました: {ex.Message}");
        }
    }
}