.NET客户端WCF如何将任务加入单线程处理队列？

首先修正接口与实现的参数不匹配问题，然后将TaskQueue整合到WCF服务中，确保请求串行执行：

1. 修正服务契约与实现的参数一致性 #

原接口定义的ExecuteRequestAsync参数为Action，但实现类中是Request，先统一参数类型：

[ServiceContract(Name="MyService", SessionMode=Session.Required)]
public interface IMyServiceContract
{
    [OperationContract()]
    Task<string> ExecuteRequestAsync(Request request);
}

2. 整合TaskQueue到WCF服务类 #

在MyService中实例化TaskQueue作为成员变量，然后在ExecuteRequestAsync中通过队列包装任务：

public class MyService: IMyServiceContract
{
    private readonly TaskQueue _taskQueue;

    public MyService()
    {
        _taskQueue = new TaskQueue();
    }

    public async Task<string> ExecuteRequestAsync(Request request)
    {
        // 将请求执行逻辑包装成Func<Task<string>>传入队列
        return await _taskQueue.Enqueue(() => 
        {
            // 同步执行后包装为异步任务
            var result = request.Execute();
            return Task.FromResult(result);
        });
    }
}

关键说明 #

• TaskQueue通过SemaphoreSlim(1)实现串行化控制：每次只有一个任务能获取信号量执行，其余任务会在队列中等待，直到前一个任务完成并释放信号量。
• 原代码中任务未执行的核心原因是未在服务类中实例化并正确调用TaskQueue，或是参数不匹配导致编译错误未正常运行。
• 如果request.Execute()本身是异步方法（返回Task<string>），可简化为：

  return await _taskQueue.Enqueue(() => request.ExecuteAsync());
  

内容的提问来源于stack exchange，提问作者VaultBoy13