中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

c#異步開發如何處理超時

c#
小樊
89
2024-10-18 21:48:57
欄目: 編程語言

在C#中,處理異步操作的超時可以采用以下方法:

  1. 使用Task.WhenAnyTask.WhenAll方法:

Task.WhenAny方法允許你在一組任務中等待任何一個任務完成。這對于超時處理非常有用。你可以創建一個CancellationTokenSource,并將其傳遞給Task.WhenAny方法。如果在指定的超時時間內沒有任務完成,你可以取消任務并處理超時。

示例:

using System;
using System.Net.Http;
using System.Threading;
using System.Threading.Tasks;

class Program
{
    static async Task Main(string[] args)
    {
        CancellationTokenSource cts = new CancellationTokenSource();
        cts.CancelAfter(TimeSpan.FromSeconds(3)); // 設置超時時間為3秒

        var task1 = FetchDataAsync("https://api.example.com/data1", cts.Token);
        var task2 = FetchDataAsync("https://api.example.com/data2", cts.Token);

        await Task.WhenAny(task1, task2);

        if (cts.IsCancellationRequested)
        {
            Console.WriteLine("請求超時");
        }
        else
        {
            var result = await task1; // 或者 await task2,取決于哪個任務先完成
            Console.WriteLine("請求成功: " + result);
        }
    }

    static async Task<string> FetchDataAsync(string url, CancellationToken cancellationToken)
    {
        using (HttpClient client = new HttpClient())
        {
            try
            {
                HttpResponseMessage response = await client.GetAsync(url, cancellationToken);
                response.EnsureSuccessStatusCode();
                return await response.Content.ReadAsStringAsync();
            }
            catch (HttpRequestException e)
            {
                if (e.Message.Contains("請求超時"))
                {
                    throw; // 重新拋出異常,讓調用者處理
                }
                else
                {
                    throw new Exception("獲取數據時發生錯誤", e);
                }
            }
        }
    }
}
  1. 使用Task.RunCancellationToken

你還可以使用Task.Run方法創建一個異步任務,并在其中使用CancellationToken來處理超時。這種方法類似于第一種方法,但將任務提交給Task.Run

示例:

using System;
using System.Net.Http;
using System.Threading;
using System.Threading.Tasks;

class Program
{
    static async Task Main(string[] args)
    {
        CancellationTokenSource cts = new CancellationTokenSource();
        cts.CancelAfter(TimeSpan.FromSeconds(3)); // 設置超時時間為3秒

        var result = await Task.Run(() => FetchDataAsync("https://api.example.com/data", cts.Token), cts.Token);

        if (cts.IsCancellationRequested)
        {
            Console.WriteLine("請求超時");
        }
        else
        {
            Console.WriteLine("請求成功: " + result);
        }
    }

    static async Task<string> FetchDataAsync(string url, CancellationToken cancellationToken)
    {
        using (HttpClient client = new HttpClient())
        {
            try
            {
                HttpResponseMessage response = await client.GetAsync(url, cancellationToken);
                response.EnsureSuccessStatusCode();
                return await response.Content.ReadAsStringAsync();
            }
            catch (HttpRequestException e)
            {
                if (e.Message.Contains("請求超時"))
                {
                    throw; // 重新拋出異常,讓調用者處理
                }
                else
                {
                    throw new Exception("獲取數據時發生錯誤", e);
                }
            }
        }
    }
}

這兩種方法都可以用于處理C#異步開發中的超時問題。你可以根據具體需求選擇合適的方法。

0
富源县| 鄂托克旗| 玛沁县| 门头沟区| 游戏| 汉阴县| 临夏县| 湘乡市| 民县| 晋州市| 名山县| 永和县| 上蔡县| 昌吉市| 双鸭山市| 蕉岭县| 万山特区| 哈密市| 苗栗市| 鄂托克前旗| 马尔康县| 于田县| 昌黎县| 沙河市| 阿勒泰市| 保定市| 红原县| 德昌县| 黎川县| 东宁县| 宝应县| 昌平区| 体育| 青州市| 松江区| 保德县| 天柱县| 桐城市| 金塔县| 舒城县| 凤冈县|