1

我有以下方法并在我的控制台应用程序中使用它：

 static async Task<List<Task<CompositeType>>> callSvcAsync(List<CompositeType> listC)
    {
        ChannelFactory<IWcfServiceLayerChannel> cn = new ChannelFactory<IWcfServiceLayerChannel>("MyWcFServiceEndpoint");
        var c = cn.CreateChannel();
        List<Task<CompositeType>> listTasks = new List<Task<CompositeType>>();
        Stopwatch sw = new Stopwatch();
        sw.Start();

        for (int i = 0; i < loopCount; i++)
        {
            Task<CompositeType> res = c.GetDataUsingDataContractAsync(new CompositeType() { BoolValue = true, StringValue = "SomeString" });
            listTasks.Add(res);
        }

        CompositeType[] value = await Task.WhenAll(listTasks);
        sw.Stop();
        Console.WriteLine(sw.Elapsed.TotalSeconds);
        listC.AddRange(value);

        **c.Dispose();**

        return listTasks;

    }

该代码调用 wcf 方法 1000 次。之后会填充一个列表对象，并且操作所消耗的时间会显示在控制台中。当我处置我的 wcf 频道时，什么也没有发生。该方法不返回调用代码。当我注释掉“\c.Dispose()”时，一切正常。

有任何想法吗？

编辑： 我对上面的问题没有答案，但以下代码有效：

async public static Task<CompositeType[]> AsyncWcfCall()
    {
        ChannelFactory<IWcfServiceLayerChannel> cn = new ChannelFactory<IWcfServiceLayerChannel>("MyWcFServiceEndpoint");
        var c = cn.CreateChannel();
        c.Open();


        List<Task<CompositeType>> listTasks = new List<Task<CompositeType>>();

        Stopwatch sw = new Stopwatch();
        sw.Start();

        for (int i = 0; i < loopCount; i++)
        {
            var res = c.GetDataUsingDataContractAsync(new CompositeType() { BoolValue = true, StringValue = "SomeString" });
            listTasks.Add(res);
        }

        return await Task.WhenAll(listTasks).ContinueWith((ct) =>
        {
            sw.Stop();
            Console.WriteLine(sw.Elapsed.TotalSeconds);
            try
            {                   
                cn.Close(); c.Dispose();
            }
            catch {  }
            return ct.Result;               
        });
    }
4

0 回答 0