聊聊多线程哪一些事儿(task)之 二 延续操作

站长

发表文章数:4245

npm脚本和package.json

hello,又见面啦,昨天我们简单的介绍了如何去创建和运行一个task、如何实现task的同步执行、如何阻塞等待task集合的执行完毕等待,昨天讲的是task的最基本的知识点,如果你没有看昨天的博客,也不要急,你可以点击下面的地址, 聊聊多线程哪一些事儿(task)之 一),先看看后,在回到这儿来继续交流学习今天的文章,谢谢!

    今天主要和大家交流分享的是:task的延续操作、task的异步取消、异步方法等知识点,希望通过本篇文章,能够给你带来一点点帮助我就高兴的不要不要的啦。当然啦,既然是交流,如果我有什么说的不对,或者说的不好的地方,大家多多指点,多多包涵,如果能够得到大牛的指点,我也会高兴的合不拢嘴,谢谢。好了,不废话了,言归正传,继续今天的分享加交流。

 

Task延续操作之WhenAny、WhenAll、ContinueWith

 

    上一篇文章我们已经知道可以通过task.wait/task.WaitAny/task.WaitAll,等方法来实现等待一个tsak或者一组task的执行完毕,这一个方法都会阻塞主线程(如果没有看一篇文章的请单击查看:聊聊多线程哪一些事儿(task)之 一),也就是这一些操作都是主流程的一个必然环节,但是我们在实际项目中,也还会遇到这样的场景,那就是主流程根本不关心task的执行结果,但是task执行完毕后,需要执行一个其他的子业务,那么这个时候WhenAny、WhenAll、ContinueWith就派上用场了,这几个方法也就专门是为这样的场景而存在的。哈哈,说了这么多,是不是觉得有点抽象,有点云里雾里的感觉,说实话,我自己都觉得说的太空洞,还不如来一个实际的场景+代码实例,这样整的更明白。

    实际业务场景:我想了半天,到得用什么样的业务场景比较合适呢,最终决定还是以昨天酒店客房数据查询为例进行为例。用户在线预订酒店时,由于真正的客房预订是需要实时的到第三接口平台预订,所以用户在自己系统下单后,并不代表真正的酒店预订成功,真正的酒店预订成功,是需要通过接口到第三方系统下单成功才算真正的预订成功,并且一个平台对接的接口都会有多个,平台最终会比价后,选择一个平台利用最大化的接口下单。这样以来,系统不可能让用户等待到第三方接口下单成功后,在返回的用户吧,这样用户是没有那么好的心情的来等待的,并且这样也很容易超时的,所以在实际项目处理上,是需要将本系统下单和第三接口预订两个步骤解耦,实现异步预订,其大致的业务逻辑是这样的。

    第一步:用户在系统发起酒店预订请求

    第二步:本系统下单成功,并返回给用户

    第三步:开启一个异步线程,到接口方下单

    异步线程的处理逻辑大概是:

        其一:具有该客房的接口方各开启一个异步线程

       其二:每一个线程的具体逻辑是,根据客房信息查询具体的客房信息(客房状态、价格、服务等)

        其三:当每一个异步线程都执行完毕后,对获取到接口数据进行对比分析,选择一个最优的接口方进行预订

        其四:预订成功后,并发送一个消息给客户

近两年的技术面试总结

    好了,下面用一个简单的实例代码来模拟上面的处理逻辑和流程

/// <summary>
/// 酒店在线预订操作
/// </summary>
/// <param name="hotelBookInfo">用户预订的酒店信息</param>
/// <returns>预订结果</returns>
private static object HotelBook(object hotelBookInfo)
{
    Console.WriteLine("用户发起了酒店预订请求!");
    Console.WriteLine("");

    // 第一步:首先本系统落地酒店预订相关操作(数据校验、数据落地、日志记录等等)
    // ---此处省略具体的业务逻辑代码,根据业务需要自由发挥

    // 第二步:根据具有该客房的酒店接口商,开启异步线程预订酒店
    //(假设第一步操作都成功的,并且 携程和艺龙都有该客房)

    // 模拟存储获取到的酒店客房数据集合
    List<string> listHotelRoomInfro = new List<string>();

    // 其一、通过传统的 new 方式来实例化一个task对象,获取 携程 的客房时时数据
    Task newCtripTask = new Task(() =>
    {
        // 具体获取业务逻辑处理...
        Thread.Sleep(new Random().Next(100, 1000));
        Console.WriteLine("携程 接口数据获取完毕!");
        Console.WriteLine("");
        listHotelRoomInfro.Add("我是来自 携程 的最新客房信息,该客房可预订,预订价格为:100元");
    });

    // 启动 tsak
    newCtripTask.Start();

    // 其二、通过工厂 factory 来生成一个task对象,并自启动:获取 艺龙 的客房数据
    Task factoryElongTask = Task.Factory.StartNew(() =>
    {
        // 具体获取业务逻辑处理...
        Thread.Sleep(new Random().Next(100, 1000));
        Console.WriteLine("艺龙 接口数据获取完毕!");
        Console.WriteLine("");
        listHotelRoomInfro.Add("我是来自 艺龙 的最新客房信息,该客房可预订,预订价格为:99元");
    });

    // 其三:通过 Task.WhenAll() 来执行 携程和艺龙的客房数据获取结果的后续处理 
    // Task.WhenAll() 可以用 Task.Factory.ContinueWhenAll()来代替,两种的效果是一样的 
    Task.Factory.ContinueWhenAll(new Task[] { newCtripTask, factoryElongTask }, (t) => { });
    Task.WhenAll(newCtripTask, factoryElongTask).ContinueWith((t) =>
    {
        Console.WriteLine("所有接口数据获取完毕,现在进行最优选择!");
        Console.WriteLine("");
        // 对比 所有接口获取的实时数据,找到一个平台利益最大化的接口预订
        // 具体的规则,每个平台都有自己的规则,在此我们简单的以价格最低为准,具体的对比逻辑就不在写了
        // 根据数据分析,最终艺龙的价格最低,所以直接预订艺龙的数据

        Console.WriteLine("艺龙接口最优,现在调用艺龙在线预订接口!");
        Console.WriteLine("");
        // 模拟调用艺龙的酒店预订接口,进行酒店预订
        Thread.Sleep(new Random().Next(100, 1000));
        // 预订成功后,系统数据落地的相关业务操作.....
        Console.WriteLine("艺龙在线预订成功,开始后续业务流程处理!");
    });

    // 第三步步:返回用户,下单成功
    Console.WriteLine("您好,你的酒店下单成功,具体的预订结果等待第三方酒店提高商的返回结果为准!谢谢");
    Console.WriteLine("");

    return "构建下单成功相关信息";
}
 

执行结果:

聊聊多线程哪一些事儿(task)之 二 延续操作

通过上面的执行结果,我们可以得出以下几点:

    其一、WhenAll里面的逻辑是在所有tsak都执行完毕后,在执行

    其二、whenAll的执行,不会影响主线程的执行

    其三、其实简单的理解,WhenAll可以理解为一个task组的异步回调

    好了,详细的举例说了whenAll的使用,至于 WhenAny 使用就不在详细说明了,其实从字面意思都能够看明白啦,就是只要所有的task集合中,只有有一个task执行完成,就在执行whenAny里面的逻辑,也就是说,wenAll和whenAny的唯一区别就是:前者是要所有task都执行完毕才执行,后者只需要有一个执行完毕就执行里面的逻辑。

    其实WhenAny 的有实际应用场景也是很多的,比如,一个具有竞争的业务逻辑中,最终只选择一个效率对快的一个,那么WhenAny就能够发挥其作用了。

    Task.WhenAll与Task.Factory.ContinueWhenAll

    Task.WhenAny 与Task.Factory.ContinueWhenAny

    这两者是一个成对的等效操作,其实你阅读两个的底层源码实现,你会发现,其实最终第底层实现都是调用的TaskFactory中的同一方法实现,所以就不在啰嗦的写一次Task.Factory.ContinueWhenAll的场景应用,需要阅读的底层源码的,可以查看下面地址进行阅读:https://blog.csdn.net/weixin_33701294/article/details/85958795

    好了,今天就写到这儿了,我仔细看了一下,文章篇幅已经够多了,本篇文章就不在介绍 task的异步取消、异步方法这两个知识点了,明天我会在单独一篇文章专门来介绍这两个知识点,想继续看明天的后续文章的小伙伴们,点关注哦,明天一定补上,谢谢!

END
为了更高的交流,欢迎大家关注我的公众号,扫描下面二维码即可关注,谢谢:

聊聊多线程哪一些事儿(task)之 二 延续操作

图解Go里面的sync.Map了解编程语言核心实现源码

未经允许不得转载:www.xssyun.com作者:站长, 转载或复制请以 超链接形式 并注明出处 xss云之家-资源网,新人技术交流平台,一个湖北娃的个人博客
原文地址:《聊聊多线程哪一些事儿(task)之 二 延续操作》 发布于2019-12-30

分享到:
赞(0) 生成海报

长按图片转发给朋友

投稿赚钱
2020年在家赚取零花钱
切换注册

登录

忘记密码 ?

您也可以使用第三方帐号快捷登录

Q Q 登 录
微 博 登 录
切换登录

注册