C# 中执行 Task.Run(async () =>）调用同一个方法只执行一次

执行 `Task.Run(async () =>)` 时，传入的是一个异步函数，该函数会在一个新的线程中执行。如果该异步函数中调用了同一个方法，确实会出现只执行一次的情况，这是因为该方法可能会被锁定，直到前一个线程执行完毕后才能被下一个线程执行。

为了避免这种情况，可以使用 `SemaphoreSlim` 类实现方法的异步锁定。在方法的开头使用 `await semaphore.WaitAsync()` 方法获取锁，在方法的结尾使用 `semaphore.Release()` 方法释放锁。这样就可以确保同一时间只能有一个线程执行该方法，避免出现只执行一次的情况。

相关问题

C#中List<Task> taskList = new List<Task>(); taskList.Add(Task.Run(async () => { try { _log.LogInformation($"Start to update Thumbnail data, ID: {activityModel.Id}"); await ProcessThumbnail(activityModel.Thumbnail, activity, user); //throw new Exception(); } catch (Exception ex) { _log.LogError("An error: Upload Thumbnail is Invalid."); throw new Exception(); } })); taskList.Add(Task.Run(async () => { try { _log.LogInformation($"Start to add Attachments data, ID: {activityModel.Id}"); await ProcessAttachments(activityModel, activity, user); } catch (Exception ex) { _log.LogError("An error: Upload Attachment is Invalid."); throw new Exception(); } })); Task.WaitAll(taskList.ToArray());里面的task只执行了一个是什么原因

在这段代码中，`Task.Run` 方法会创建一个新的线程，并在该线程中执行传入的异步函数。`List<Task>` 中包含两个 `Task`，分别对应两个异步函数，即 `ProcessThumbnail` 和 `ProcessAttachments`。

在调用 `Task.WaitAll(taskList.ToArray())` 方法时，程序会等待所有的 `Task` 执行完毕后再继续往下执行。如果其中任意一个 `Task` 抛出了异常，整个程序会崩溃。

如果只有一个 `Task` 执行了，有可能是因为其中一个 `Task` 出现了异常，导致该 `Task` 执行失败，程序终止了。你可以通过在 `catch` 块中记录异常信息或者使用调试工具来确认是否有异常抛出。另外，你还可以在调用 `Task.WaitAll(taskList.ToArray())` 方法前，输出一些日志信息来确认程序的执行情况。

C# public Task Execute(IJobExecutionContext context) { return Task.Run(() => {}}这段定时服务代码，需要每次记录执行时间，并可以获取上次执行时间

在这段代码中，使用了.NET框架的异步编程模型`Task.Run`来执行一个工作线程。`Execute`方法接收一个`IJobExecutionContext`作为参数，通常用于在.NET Core的定时任务（如Quartz.NET）中处理异步操作。为了每次执行时记录开始时间并获取上次执行时间，你需要对代码做些修改：

using System.Threading.Tasks;
using System.Diagnostics;

public async Task Execute(IJobExecutionContext context)
{
    // 获取上一次执行时间（假设已经存在）
    var lastExecutionTime = GetLastExecutionTime();

    // 记录开始执行的时间
    var startTime = DateTime.Now;
    
    try
    {
        await Task.Run(() =>
        {
            // 你的实际业务逻辑
            DoSomething();
            
            // 在完成任务后更新执行时间（例如存储到数据库或日志文件）
            UpdateExecutionTime(startTime);
        });
    }
    catch (Exception ex)
    {
        // 处理异常，保存错误信息并记录执行时间
        LogError(ex, startTime);
    }
    
    // 更新最后一次执行时间
    SetLastExecutionTime(startTime);

    // 返回一个表示任务已完成的空Task，因为实际上异步操作已经结束
    return Task.CompletedTask;
}

private void DoSomething()
{
    // ... 定义你的业务逻辑
}

private DateTime GetLastExecutionTime()
{
    // 从持久化位置获取上次执行时间
}

private void UpdateExecutionTime(DateTime startTime)
{
    // 存储当前执行时间
}

private void LogError(Exception ex, DateTime startTime)
{
    // 记录错误日志，包含开始执行时间和异常信息
}

private void SetLastExecutionTime(DateTime currentTime)
{
    // 更新最后执行时间到持久化位置
}

现在，每当`Execute`方法被调用时，都会记录开始执行时间并在任务完成后更新上一次执行时间。