How can push be executed in multithreading without consuming cpu

[a645010545]

Is your feature request related to a problem? Please describe.

public static class MessageMiddleware
{
private static readonly SemaphoreSlim _semaphore = new SemaphoreSlim(1, 1);
private static ConnectionFactory _factory;
private static IConnection _connection;
private static IChannel _channel;
private static string RabbitMQHostName = App.Configuration["RabbitMQConfig:HostName"];
private static string RabbitMQUserName = App.Configuration["RabbitMQConfig:UserName"];
private static string RabbitMQPassword = App.Configuration["RabbitMQConfig:Password"];

public static async Task Init()
{
    _factory = new ConnectionFactory
    {
        HostName = RabbitMQHostName,
        UserName = RabbitMQUserName,
        Password = RabbitMQPassword,
        AutomaticRecoveryEnabled = true
    };
    // 初始化连接和通道
    _connection = await _factory.CreateConnectionAsync();
    _channel = await _connection.CreateChannelAsync();
    //await Task.CompletedTask;
}

/// <summary>
/// 发送到Rabbit方法
/// </summary>
/// <param name="exchange">交换机</param>
/// <param name="deliveryMode">设置消息是否持久化，1： 非持久化 2：持久化</param>
/// <param name="data">数据</param>
public static async Task Push(string exchange, object data)
{
    await _semaphore.WaitAsync();
    try
    {
        if (!_connection.IsOpen)
        {
            // 连接断开时尝试重新创建连接
            _connection = await _factory.CreateConnectionAsync();
            _channel = await _connection.CreateChannelAsync();
        }
        else if (!_channel.IsOpen)
        {
            // 通道断开时尝试重新创建通道
            _channel = await _connection.CreateChannelAsync();
        }
        var jsonStr = JsonConvert.SerializeObject(data);
        var bytes = Encoding.UTF8.GetBytes(jsonStr);
        var properties = new BasicProperties();
        properties.DeliveryMode = DeliveryModes.Persistent;
        await _channel.BasicPublishAsync(exchange, string.Empty, true, properties, bytes);
    }
    catch (Exception ex)
    {
        Console.WriteLine($"RabbitMQ Push ERROR:{ex.Message}\r\n{ex.StackTrace}");
    }
    finally
    {
        _semaphore.Release();
    }
}

}

await MessageMiddleware.Init();
// 定义并发任务数量
const int concurrentTasks = 10000000;

// 创建任务数组
var tasks = new Task[concurrentTasks];
for (int i = 0; i < concurrentTasks; i++)
{
tasks[i] = Task.Run(async () =>
{
await MessageMiddleware.Push("remoteconfiguration", new { TokenId = "123456" });
});
}

// 等待所有任务完成
await Task.WhenAll(tasks);

Console.WriteLine("All push operations completed.");
Console.ReadLine();

Describe the solution you'd like

How can push be executed in multithreading without consuming cpu

Describe alternatives you've considered

No response

Additional context

No response