0

我已经开发了一个连接设备并与之操作的库。例如:

public bool Connect(string ip)
{
    try
    {
        // try connect to device
    }
    catch (Exception ex)
    {
        // trow custom exception
    }
}

这没关系,但现在我决定将 TPL 包含在我的库中。

我面临的问题是如何返回值的逻辑。您将传递一个 IP 列表,而不是传递一个 IP。想象一下,您想连接 10 台设备,其中 5 台正常,而另外 5 台出现故障,我想象的代码如下:

public Dictionary<Device, bool> Connect(List<Device> device)
{
    try
    {
        // TPL try connect to device
    }
    catch (AggregatedException ex)
    {
        // trow custom exception
    }
}

如果有人调用此方法,他们只会收到例外情况,在这种情况下,这很容易,但例如,如果我有另一种方法,例如Dictionary<Device, List<Logs>> GetLogs(List<Device> device)我将有 5 台设备有数据和 5 台设备出现故障。

返回正确连接结果和故障连接错误的最佳方法是什么?连接失败可能有多种原因。

更新

我试过这个:

    public Dictionary<int, Task<string>> GetData3(int value)
    {
        Dictionary<int, Task<string>> dic = new Dictionary<int, Task<string>>();
        Task<string>[] tasks = new Task<string>[value];
        for (int i = 0; i < value; i++)
        {
            tasks[i] = Task.Factory.StartNew<string>((stateObject) =>
            {
                var a = (int)stateObject;
                return a + " Test";
            }, value);
            dic.Add(i, tasks[i]);
        }
        Task.WaitAll(tasks);

        return dic;
    }

在 WS 客户端中:

        Service1Client sc = new Service1Client();
        var a = sc.GetData3(5);

如果我闯入return dic我可以看到结果:

Id = 1, Status = RanToCompletion, Method = "{null}", Result = "5 Test"

但在var a我只看到:

Id = 1, Status = WaitingForActivation, Method = "{null}", Result = "{Not yet computed}"
4

1 回答 1

1

您可以返回一个Dictionary<Device, Task<Whatever>>Whatever每个设备的结果在哪里)。您可以立即返回,已开始连接到每个设备。然后,任务将代表(基于每个设备)连接是否已完成、失败或仍在进行中。

除此之外,使用异步结果的任务几乎是使用 TPL 的惯用方式......并且在 C# 5 中通过 async/await 变得更容易。

如果调用者想要等待所有任务完成并聚合任何异常,他们可以这样做。

于 2013-02-15T22:26:51.473 回答