2

我正在尝试构建一个 WCF 服务 -

  1. 是单实例
  2. 允许客户端向函数发出多个请求（例如 StartJob）

  3. StarJob(request) 将请求“排队”到在并发任务计划上运行的 TaskFactory（一个实例）（按示例实现）

  4. 随着任务工厂中的任务完成，返回响应

  5. 当任务正在运行并且有更多请求进入时，它们会排队（提供达到最大并发数）

目标是构建一个系统，接受来自客户端的请求并将它们排队等待处理。

目前，我的代码（如下所示）同时运行所有请求，而不考虑任务调度程序的最大并发数。

问题

  1. 我错过了什么？
  2. 我可以看看任何好的例子/参考吗？（我相信这不是一个不常见的用例）

代码

服务

[ServiceContract]
public interface ISupportService
{
    [OperationContract]
    Task<TaskResponse> StartTask(TaskRequest taskRequest);
}

服务

[ServiceBehavior(InstanceContextMode = InstanceContextMode.Single, ConcurrencyMode = ConcurrencyMode.Multiple)]
public class SupportService : ISupportService
{
    private static TaskRequestHandler taskRequestHandler;

    public SupportService()
    {        
        taskRequestHandler = TaskRequestHandler.GetInstance();         
    }

    public Task<TaskResponse> StartTask(TaskRequest taskRequest)
    {
        var tcs = new TaskCompletionSource<TaskResponse>();

        if (!IsTaskRequestValid(taskRequest))
            tcs.SetResult(new TaskResponse()});

        taskRequestHandler.StartTaskAsync(taskRequest, lockHandler).ContinueWith(task => { tcs.SetResult(task.Result); });

        return tcs.Task;
    }    
}

任务请求处理程序

public class TaskRequestHandler
{
    private ConcurrentTaskScheduler taskScheduler;
    private TaskFactory taskFactory;

    private TaskRequestHandler()
    {
        taskScheduler = new ConcurrentTaskScheduler(2);
        taskFactory = new TaskFactory(taskScheduler);
    }

    private Task<TaskResponse> StartTaskAsync (TaskRequest request, LockHandler lockHandler)
    {
        var tcs = new TaskCompletionSource<TaskResponse>();
        taskFactory.StartNew(() =>
        {
            //Some task with tcs.SetResults()
        });

        return tcs.Task;
    }
}
4

1 回答 1

0

啊啊！对我来说是一个很大的失误。执行的操作taskFactory在我预期之前完成。因此，所有任务似乎都在并行运行。

我更新了动作代码以正确监控动作完成并引发正确的回调，上面的代码运行良好。

然而，做了一个小改动——

  • 不需要StartTask(TaskRequest taskRequest)返回 a Task。相反，只需返回TaskResponsewill 就足够了（因为 WCF 负责 each 的 Async 和 Sync 功能OperationContract）
于 2016-08-05T01:17:00.920 回答