运行并行任务c#

本文关键字：并行任务 运行 | 更新日期: 2023-09-27 18:24:15

在windows商店应用程序项目中，我有一个函数，我在foreach周期内多次调用它来填充一些对象

方法头看起来像这个

private async Task createInvite(JsonValue item, string meetingid, List<MeetingInvitee> listInvitees)

我试着在类似的并行任务中运行这个

List<Task> ts = new List<Task>();
foreach (JsonValue item in invitees)
{
    ts.Add(createInvite(item, meetingid, listInvitees));
}
await Task.WhenAll(ts);

但它似乎不会创建同时运行的任务。这大约需要10秒。

如果我用这个

//List<Task> ts = new List<Task>();
foreach (JsonValue item in invitees)
{
    //ts.Add(createInvite(item, meetingid, listInvitees));
      await createInvite(item, meetingid, listInvitees);
}
//await Task.WhenAll(ts);

它也需要大约10秒。

我的第一个选项不是同时运行多个任务吗？

编辑

private async Task createInvite(JsonValue item, string meetingid, List<MeetingInvitee> listInvitees)
{
    try
    {
        Stopwatch st = Stopwatch.StartNew();
        MeetingInvitee org = new MeetingInvitee();
        MeetingInvitee altorg = new MeetingInvitee();
        JsonObject invitee2;
        JsonObject invitee;
        InviteeDB InviteeForDB = new InviteeDB();
        GappService gappservice = new GappService();
        MeetingInvitee inv = new MeetingInvitee();

        JsonObject.TryParse(item.Stringify(), out invitee2);
        invitee = invitee2["user"].GetObject();

        if (invitee2.ContainsKey("_id"))
        {
            inv.id = invitee2["_id"].GetString();
            InviteeForDB.Id = invitee2["_id"].GetString();
        }
        else
        {
            InviteeForDB.Id = invitee2["user"].GetString();
        }
        if (invitee2.ContainsKey("status"))
        {
            if (invitee2["status"].ValueType == JsonValueType.Null)
            {
                inv.status = string.Empty;
                InviteeForDB.Status = string.Empty;
            }
            else
            {
                inv.status = invitee2["status"].GetString();
                InviteeForDB.Status = invitee2["status"].GetString();
            }
        }
        Stopwatch st2 = Stopwatch.StartNew();
        if (invitee2.ContainsKey("user"))
        {
            if (invitee2["user"].ValueType != JsonValueType.Null)
            {
                User iUser = new User();
                //iUser.Id = InviteeForDB.UserID;
                JsonSerializerSettings sett = new JsonSerializerSettings();
                sett.NullValueHandling = NullValueHandling.Ignore;
                iUser = JsonConvert.DeserializeObject<User>(invitee.Stringify(), sett);
                inv.user = iUser;
            }
            else
                return;
        }
        else
            return;
        InviteeForDB.MeetingID = meetingid;
        ds.inviteeRepository.Add(InviteeForDB);
        listInvitees.Add(inv);
    }
    catch (Exception e)
    {
        Debug.WriteLine(e.Message);
    }
}

运行并行任务c#

您的代码实际上不是异步的（它没有await语句），所以所有的工作都发生在for循环内的初始createInvite()调用中。

您可以使用Parallel.ForEach()使其实际并行运行，但这会破坏您的代码，因为它实际上不是线程安全的。

您的方法没有真正的异步。简单地添加async修饰符并不能神奇地使其异步，或者以并行执行，我认为这正是你想要做的。它所做的只是向编译器发出信号，表明需要生成状态机。按原样，此代码将完全同步执行。

您可以使用Task.Run或Parallel.ForEach在线程池线程上显式调用您的方法，但从代码来看，这样做似乎根本不安全。在进行任何进一步的操作之前，请尝试将CreateInvite隔离为线程安全的，然后查看上面提到的选项之一。

相关文章：