[C#] 非同期アクションの基本と活用法

using System;
using System.Threading.Tasks;
class Program
{
    static async Task Main(string[] args)
    {
        // 非同期メソッドの呼び出し
        await ExampleAsync();
    }
    static async Task ExampleAsync()
    {
        // 3秒待機する非同期タスク
        await Task.Delay(3000);
        Console.WriteLine("非同期処理が完了しました");
    }
}

// 非同期メソッドの定義
async Task SampleAsync()
{
    // 非同期処理を実行
    await Task.Delay(1000);
    Console.WriteLine("非同期メソッドが実行されました");
}

async Task<int> CalculateAsync()
{
    // 非同期に計算を実行
    await Task.Delay(500);
    return 42; // 計算結果を返す
}

async Task<string> FetchDataAsync()
{
    // データを非同期に取得
    await Task.Delay(2000);
    return "データ取得完了";
}

using System;
using System.Threading.Tasks;
class Program
{
    static async Task Main(string[] args)
    {
        // 非同期メソッドの呼び出し
        await PerformAsyncTask();
    }
    static async Task PerformAsyncTask()
    {
        // 非同期に3秒待機
        await Task.Delay(3000);
        Console.WriteLine("非同期タスクが完了しました");
    }
}

async Task<string> GetDataAsync()
{
    // 非同期にデータを取得
    await Task.Delay(2000);
    return "データ取得完了";
}

async Task<string> FetchDataAsync()
{
    try
    {
        // 非同期にデータを取得
        await Task.Delay(2000);
        throw new Exception("データ取得エラー");
    }
    catch (Exception ex)
    {
        Console.WriteLine($"エラーが発生しました: {ex.Message}");
        return "エラー";
    }
}

async Task<string> LoadDataAsync()
{
    // 非同期にデータをロード
    await Task.Delay(2000).ConfigureAwait(false);
    return "データロード完了";
}

using System;
using System.Threading.Tasks;
using System.Windows.Forms;
public class MainForm : Form
{
    private Button loadButton;
    public MainForm()
    {
        loadButton = new Button { Text = "データをロード", Dock = DockStyle.Top };
        loadButton.Click += async (sender, e) => await LoadDataAsync();
        Controls.Add(loadButton);
    }
    private async Task LoadDataAsync()
    {
        // 非同期にデータをロード
        await Task.Delay(2000);
        MessageBox.Show("データロード完了");
    }
}

using System.Threading.Tasks;
using Microsoft.AspNetCore.Mvc;
public class DataController : Controller
{
    [HttpGet("data")]
    public async Task<IActionResult> GetDataAsync()
    {
        // 非同期にデータを取得
        await Task.Delay(2000);
        return Ok("データ取得完了");
    }
}

using System.Data.SqlClient;
using System.Threading.Tasks;
public class DatabaseService
{
    private readonly string connectionString = "your_connection_string";
    public async Task<string> GetDataFromDatabaseAsync()
    {
        using (var connection = new SqlConnection(connectionString))
        {
            await connection.OpenAsync();
            using (var command = new SqlCommand("SELECT TOP 1 Name FROM Users", connection))
            {
                var result = await command.ExecuteScalarAsync();
                return result?.ToString() ?? "データなし";
            }
        }
    }
}

using System.IO;
using System.Threading.Tasks;
public class FileService
{
    public async Task<string> ReadFileAsync(string filePath)
    {
        using (var reader = new StreamReader(filePath))
        {
            // 非同期にファイルを読み込む
            return await reader.ReadToEndAsync();
        }
    }
}

async Task<string> FetchDataAsync()
{
    // 非同期にデータを取得し、コンテキストの切り替えを防ぐ
    await Task.Delay(2000).ConfigureAwait(false);
    return "データ取得完了";
}

// 非同期にデータを取得するメソッド
async Task<string> GetDataAsync()
{
    await Task.Delay(1000);
    return "データ取得完了";
}

private readonly object lockObject = new object();
private int sharedResource = 0;
void UpdateResource()
{
    lock (lockObject)
    {
        // 共有リソースを安全に更新
        sharedResource++;
    }
}

async IAsyncEnumerable<int> GenerateNumbersAsync()
{
    for (int i = 0; i < 5; i++)
    {
        await Task.Delay(500); // 非同期に待機
        yield return i; // 値を返す
    }
}
async Task ProcessNumbersAsync()
{
    await foreach (var number in GenerateNumbersAsync())
    {
        Console.WriteLine($"数値: {number}");
    }
}

using System;
using System.Net.Http;
using System.Threading.Tasks;
public class ApiService
{
    private readonly HttpClient httpClient = new HttpClient();
    public async Task<string> GetApiDataAsync(string url)
    {
        // 非同期にAPIを呼び出し、レスポンスを取得
        HttpResponseMessage response = await httpClient.GetAsync(url);
        response.EnsureSuccessStatusCode();
        return await response.Content.ReadAsStringAsync();
    }
}

using System;
using System.Threading;
using System.Threading.Tasks;
public class TaskService
{
    public async Task PerformCancellableTaskAsync(CancellationToken cancellationToken)
    {
        for (int i = 0; i < 10; i++)
        {
            // キャンセルが要求されたか確認
            cancellationToken.ThrowIfCancellationRequested();
            await Task.Delay(500); // 非同期に待機
            Console.WriteLine($"タスク進行中: {i}");
        }
    }
}

using System;
using System.Threading.Tasks;
public class ParallelService
{
    public async Task ExecuteParallelTasksAsync()
    {
        var task1 = Task.Delay(1000);
        var task2 = Task.Delay(2000);
        var task3 = Task.Delay(1500);
        // 複数のタスクを並列に実行
        await Task.WhenAll(task1, task2, task3);
        Console.WriteLine("すべてのタスクが完了しました");
    }
}

using System;
using System.Threading.Tasks;
public class EventService
{
    public event Func<Task> OnDataProcessed;
    public async Task ProcessDataAsync()
    {
        // データ処理を非同期に実行
        await Task.Delay(1000);
        Console.WriteLine("データ処理完了");
        // 非同期イベントをトリガー
        if (OnDataProcessed != null)
        {
            await OnDataProcessed.Invoke();
        }
    }
}