使用post()时没有调用处理程序，直接调用函数时工作(io_context有工作)

使用post()时没有调用处理程序，直接调用函数时工作(io_context有工作)是指在使用Boost.Asio库进行网络编程时的一种情况。

Boost.Asio是一个用于网络和底层I/O编程的跨平台C++库，它提供了异步I/O操作和事件驱动编程模型。在使用Boost.Asio时，可以通过post()函数将工作项提交给io_context对象，以便在io_context的事件循环中执行。

在调用post()函数时，我们可以传递一个处理程序（回调函数）作为参数，当io_context的事件循环运行到适当的时机时，该处理程序将会被调用。处理程序通常用于处理完成的异步操作。

然而，如果我们直接调用函数而没有调用处理程序，只是提交了工作项给io_context，那么在io_context的事件循环中，并不会执行该函数。这是因为在Boost.Asio中，只有通过异步操作完成后才会调用相应的处理程序。

虽然这种用法可能不常见，但也有一些特殊情况下可以使用。例如，当我们需要在当前线程中执行一些操作，而不希望阻塞主线程时，可以使用这种方式。但需要注意的是，这种方式可能会导致阻塞io_context的事件循环，因此需要谨慎使用。

腾讯云提供了一系列与云计算相关的产品，可以帮助开发者构建可靠、高效的云原生应用。以下是一些腾讯云产品的介绍和相关链接：

云服务器（CVM）：提供可扩展、高性能的云服务器实例，支持多种操作系统和应用场景。了解更多：云服务器产品介绍
云数据库MySQL：基于云服务器提供的高性能、高可用的MySQL数据库服务，适用于各类Web应用、移动应用等。了解更多：云数据库MySQL产品介绍
腾讯云容器服务（TKE）：基于Kubernetes的容器化应用托管服务，提供高度可扩展的容器集群管理能力。了解更多：腾讯云容器服务产品介绍
腾讯云函数（SCF）：无服务器函数计算服务，支持事件驱动的函数运行模式，实现按需计算和资源自动伸缩。了解更多：腾讯云函数产品介绍
腾讯云对象存储（COS）：安全可靠的大规模分布式存储服务，适用于图片、音视频、文档等各类文件存储和分发。了解更多：腾讯云对象存储产品介绍

请注意，以上介绍的产品仅作为示例，具体产品选择应根据项目需求和实际情况进行评估。

相关·内容

asio 调度器实现 - operation 调度详解

一个业务传入的 lambda 函数被处理的流程大致如下: 1....对应工作线程在执行 io_context::run() 时, 对应的 operation 会被取出, 相关的 lambda 函数在执行 io_context::run() 的线程上被执行. post()...member alias templates : rebind_alloc 所以对于op::ptr来说, 它实现了特定对象(这里就是我们的executor_op)的内存申请, 以及reset()时对特定对象调用析构函数并进行内存释放操作..., 大概也会有数千行的代码量, 不是在非常特定的业务使用场景下, 没有太多取巧的方法...., 则直接无锁方式将任务推送到线程的op_queue上, 算是一个Fast Path实现了. 1.4 post()过程小结 post()的过程, 总结来看, 是将外部传入的函数对象做类型擦除后, 利用统一的

5826 0

C++ Boost 异步网络编程基础

调用io_service的run成员函数可以等待异步操作完成。当异步操作完成时，io_service会从操作系统获取结果，再调用相应的处理函数（handler）来处理后续逻辑。...通常，run() 方法会一直运行，直到没有更多的工作需要完成，即直到没有未完成的异步操作。...成员函数 run_print：使用了成员函数 run_print 作为定时器回调函数，无需再使用 boost::bind 绑定 this 指针，直接使用类的成员变量，提高了代码的简洁性。...start() 函数启动异步等待连接操作，当有客户端连接请求时，触发 accept_handler。...accept_handler 函数：当有客户端连接成功时，该函数会被调用。递归调用 start()，以便继续等待新的连接请求。输出远程客户端的IP地址。

5701 0

c++异步：asio的scheduler实现！

利用c++11引入的lambda和函数对象，我们的通用任务可以很好的包装成lambda之后post()到某个io_context上，然后在io_context::run()的时候执行。...以及它的member alias templates : rebind_alloc 所以对于op::ptr来说，它实现了特定对象(这里就是我们的executor_op)的内存申请，以及reset()时对特定对象调用析构函数并进行内存释放操作...（二）strand的实现细节因为strand的特殊性，肯定是没有办法直接使用前面介绍的普通任务的post()机制和相关的operation包装来完成相关的封装的，我们分为三个部分来分析strand的实现...实际上我们也可以很直白的来理解它，当strand刚开始工作时，我们推送一个任务，必然走的是2这个分支，如果推送的任务没有得到及时的执行，那么locked_标识依然还是true，则后续推送的任务会被加入到...浅谈函数调用！甜skr人！程序员专属七夕表白神器，成功率100%

1.5K1 0

协程（coroutine）简介

系统在维护线程时需要分配额外的空间，所以线程数的增加还是会提高内存资源的消耗总结如果线程之间没有竞争关系、线程占用的内存资源较少且对延时不是非常敏感或者说线程创建不频繁（数分钟创建一次），那么直接在使用的时候创建新的线程...输入和输出之间用函数变换来连接，函数之间也只对输入输出负责，因此我们可以很轻松地通过将这些函数调用分发到其他线程上的方法来实现异步响应式编程中的逻辑单元也不能阻塞，否则也有耗尽工作线程的风险；非阻塞式...注意，如果 setcontext 执行成功，那么调用 setcontext 的函数将不会返回，因为当前 CPU 的上下文已经交给其他函数或者过程了，当前函数完全放弃了对 CPU 的“所有权” 应用：当信号处理函数需要执行的时候...协程对 CPU/IO 的影响协程的目的在于剔除线程的阻塞，尽可能提高 CPU 的利用率很多服务在处理业务时需要请求第三方服务，向第三方服务发起 RPC 调用。...RPC 调用的网络耗时一般耗时在毫秒级别，RPC 服务的处理耗时也可能在毫秒级别，如果当前服务使用同步调用，即 RPC 返回后才进行后续逻辑，那么一条线程每秒处理的业务数量是可以估算的假设每次业务处理花费在

1K2 0

MongoDB网络传输处理源码实现及性能调优-体验内核性能极致设计

io_context::stop()停止IO调度处理调用scheduler::stop()接口io_context::run_one_until()1....如果全局队列为空，则调用epoll_wait()获取网络IO事件处理调用schedule::wait_one()io_context::post()任务入队到全局队列调用scheduler::post_immediate_completion...()io_context::dispatch()1.如果调用该接口的线程已经运行过全局队列中的任务，则直接继续由本线程运行该入队的任务 2.如果不满足条件1条件，则直接入队到全局队列，等待调度执行如果条件...io_context上下文的上述接口，除了dispatch在某些情况下直接运行handler外，其他接口最终都会间接调用scheduler调度类接口。...全局任务入队的时候有两种方式，一种是io_context::dispatch方式，另一种是io_context::post。

1.1K4 0

基于Asio库的定时器,封装实现好用的定时任务

比如以下使用,同步使用：第一个参数是asio::io_context，第二个参数设置定时器现在开始3秒后终止。wait()是一个阻塞等待，3秒后定时器终止时返回。...<< std::endl; return 0; } 异步使用时： async_wait() 执行异步等待，设置回调函数Print，当异步操作结束后（此处即定时器结束后）该函数会被调用。...Asio保证回调句柄仅仅能被run()启动的当前线程所调用。如果run() 函数不执行，用于异步等待完成时的回调函数（此处即Print()）将永远不会被调用。...async_wait回调函数的签名为 void (std::error_code)，传递额外的参数时需要使用bind。Print函数中，计数小于3时，expires_at()推迟定时器的终止时间。...计数大于3时，run()函数返回。

2K2 0

C++ 异步编程之协程代码实践

io_context; // 使用 post 提交一个简单的任务 asio::post(io_context, []() { std::cout ，表明它是一个异步协程。 post 函数用于提交一个 lambda 函数到 io_context。此 lambda 函数直接打印一条消息。...函数内部使用boost::asio::async_initiate来包装异步操作。内部逻辑: 连接到信号，当信号触发时，使用boost::asio::post将回调函数发布到指定的执行器上执行。...AsyncWaitSignalWithTimeout 这个函数在AsyncWaitSignal的基础上增加了超时机制。如果在指定的时间内信号没有被触发，则触发超时处理逻辑。...使用async_wait等待两个操作中的任意一个完成。根据完成的操作类型（定时器或信号），调用相应的处理逻辑。 AsyncConnectSignal 这个函数用于将用户定义的回调连接到一个信号。

1031 0

asio 调度器实现 - strand 实现详解

. ---- 2 strand 的实现细节因为strand的特殊性, 肯定是没有办法直接使用前面介绍的普通任务的post()机制和相关的operation包装来完成相关的封装的, 我们分为三个部分来分析...Function类型退化后, 继续调用strand_service::post(), 注意此处直接抛弃了外部传递的allocator, 应该是1.16版本实现不完整, 直接没给strand的operation...匹配正确的allocator, 翻阅1.22的代码实现, 这部分的allocator是有被正确处理的, 对于我们来说这处细节影响不大, 我们直接忽略. ---- 2.2.2 level 2: strand_service..., 略有差异的地方是此处使用的不是execution_op, 而是使用了另外一个类型 completion_handler, 该类型的实现与execution_op基本没有太大的差别,...实际上我们也可以很直白的来理解它, 当strand刚开始工作时, 我们推送一个任务, 必然走的是2这个分支, 如果推送的任务没有得到及时的执行, 那么locked_标识依然还是true, 则后续推送的任务会被加入到

9972 0

asio调度器实现 - 总览篇

::allocator(my_allocator)); asio::execution::execute(ex3, []{ /*...*/ }); 如上面的代码所示, property主要通过三个模板函数来工作...借助C++11引入的lambda和函数对象，我们可以将通用任务包装成lambda，然后使用post()方法将其提交到某个io_context上, 整个任务派发的过程也是现在众多游戏引擎所使用的lambda...每个JobSlot会创建一组线程池用于其关联的asio::io_context的任务的调度, 也就是每个线程调用io_context::run()来执行投递来的任务. 4....主线程(逻辑线程)是比较特殊的存在, 我们一般是使用手动驱动其工作的模式. 5....另外, 很多时候我们处理异步任务的时候, 是有具体的返回值预期的. 所以ASIO也需要提供相应的定制点, 方便业务扩展相关的异步设施.

6471 0

优雅的实现多线程环境下的协程调度 - 再谈 ASIO 与 Coroutine

借助C++11引入的lambda和函数对象，我们可以将通用任务包装成lambda，然后使用post()方法将其提交到某个io_context上, 整个任务派发的过程也是现在众多游戏引擎所使用的lambda...每个JobSlot会创建一组线程池用于其关联的asio::io_context的任务的调度, 也就是每个线程调用io_context::run()来执行投递来的任务. 4....主线程(逻辑线程)是比较特殊的存在, 我们一般是使用手动驱动其工作的模式. 5...., 有以下这些方案可供选择. ---- 3.1 解决问题的思路 - 方案A 前文>中我们提到过, 我们已经有一版在单一线程下工作良好的 coroutine 封装了..., 当线程下次被工作线程Resume()时, 才会真正的执行Terminate()操作.

8902 0

1. 基于 c++ executions的异步实现 - 从理论到实践

借助C++11引入的lambda和函数对象，我们可以将通用任务包装成lambda，然后使用post()方法将其提交到某个io_context上, 整个任务派发的过程也是现在众多游戏引擎所使用的lambda...hint] 需要注意的是asio没有使用句柄式的方式对operation进行管理, 在需要返回值的情况下, 是通过额外的async_result的模板来完成异步传值等操作的....每个JobSlot会创建一组线程池用于其关联的asio::io_context的任务的调度, 也就是每个线程调用io_context::run()来执行投递来的任务. 4....主线程(逻辑线程)是比较特殊的存在, 我们一般是使用手动驱动其工作的模式. 5....业务侧使用JobType枚举来选择对应的asio::io_context来进行任务的投递, 这样就对业务侧适当隔离了asio本身, 枚举也易于记忆和使用. 2.1.2 JobType 简介 JobType

2771 0

MongoDB transport_layer网络传输层模块源码实现四

_ioContext->dispatch(std::move(wrappedTask)); } else { //入队 io_context::post //task...如果带有递归标识kMayRecurse，则通过ioContext->dispatch()接口入队，该接口再ASIO底层实现的时候实际上没有真正把任务添加到全局队列，而是直接当前线程继续处理，这样就实现了递归调用...如果没有携带kMayRecurse递归标识，则task任务通过ioContext->post()需要入队到全局队列。...判断本线程是否比较”闲”，如果是则直接销毁退出。3. 线程创建起来进行初始线程名设置、线程主循环一些计数处理等。...Mongodb在启动初始化的时候，会创建一个线程名为”worker-controller”的控制线程，该线程主要工作就是判断线程池中是否有充足的工作线程来处理asio库中全局队列op_queue_中的

5852 0

C++异步：asio的coroutine实现！

利用c++11引入的lambda和函数对象，我们的通用任务可以很好的包装成lambda之后post()到某个io_context上，然后在io_context::run()的时候执行。...async_initiate()函数的作用我们可以简单理解为根据传入的Initiation类型来自动采用合适的方式执行初始化操作，主要有两种情况: 传入的是一个函数对象，则最终直接调用该函数对象。...传入带intialise()函数的对象，则调用这个initalise()函数。...对于示例，此处传入的是detail::initate_co_spawn这个函数对象，则直接调用它的operator()操作符。...asio对父子协程的管理机制，asio此处的实现比较特殊，没有借助全局的调度器，而是通过对象之间的串接完成了父子协程的执行切换和恢复处理。

3.5K2 1

windows完成端口（一）

但是如果是这样的话，如果同一时间有大量的连接来了，可能就要逐个接受连接了，相当于一群人排队进入一个门里面，那有没有更好的方法呢？...有，windows提供了一个AcceptEx函数，在创建完侦听函数之后，调用这个函数，那么将来在完成端口的工作线程里面如果有接受新连接动作，则无需调用accept或者AcceptEx，操作系统自动帮你接受新连接...当然msdn上说使用这个函数最好不要直接使用，而是通过相应API获取该函数的指针，再调用之（https://msdn.microsoft.com/en-us/library/windows/desktop...写过网络通信程序的人都知道，尤其是服务器端程序，我们不能直接调用send和recv这类函数进行数据收发，因为当tcp窗口太小时，数据发不出去，send会阻塞线程，同理，如果当前网络缓冲区没有数据，调用recv...那有没有一种模型，不仅能通知我们数据可读和可写，甚至当数据可读或者可写时，连数据的收发工作也帮我们做好了？有，这就是windows的完成端口模型。

2.3K5 0

关于windows完成端口（IOCP）的一些理解（一）

7.1K9 0

asio 调度器实现 - timer 实现详解

使用up_heap()调整heap_entry到合适的位置 4. timer链表的处理 5....返回新的timer是否是根节点(如果是根节点, 则表示整个timer_queue的最小expired时间有调整, 外围的Timer Scheduler需要做额外的处理) 其他的cancel_timer...中取出超时的任务, 并投递operation回io_context执行它们. 2.2 winrt_timer_scheduler 实现 winrt_timer_scheduler对应的核心实现其实就是它的线程工作函数..., 这种情况winrt_time_scheduler也是有相关的处理的: template void winrt_timer_scheduler::schedule_timer...当我们使用epoll_reactor作为timer scheduler的时候, 整体系统的工作流程图如下: 图引用自参考3: 深入学习定时器 timer_fd是linux2.6.25加入的功能,

6229 0

PostgreSQL16-新特性-新增IO统计视图：pg_stat_io

但这些信息不完整，没有明确考虑autovacuum活动，也没有让您了解刷写的根本原因（例如缓冲区驱逐）。...2)如果页驱逐时被标记为脏，进程驱逐时也会将老页写页磁盘。这两个方面对于调整共享缓冲区的大小都很重要。pg_stat_io可以通过跟踪系统中每个后端类型的evictions清楚的显示。...2.3通过autovacuum和手动VACUUM跟踪累积的IO活动事实上，每个 Postgres 服务器偶尔都需要 VACUUM - 无论您是手动安排它，还是让 autovacuum 为您处理它。...2.4批量读/写策略的可见性（顺序扫描和COPY）你在 Postgres 中使用过 COPY 加载数据吗？或者使用顺序扫描从表中读取数据？...相反，Postgres 使用一个特殊的专用环形缓冲区来确保大多数共享缓冲区不受此类大型活动的干扰。以前pg_stat_io，几乎不可能理解 Postgres 中的此活动，因为根本没有对其进行跟踪。

9034 0

【浅谈Chromium中的设计模式（二）】——prepost和Delegate模式

在《程序员修炼之道：从小工到专家》中专门有一条讲的就是契约式编程（按合约设计）。 DesignbyContract的核心是断言（assertion）。...具体函数调用可以参考网上文章（http://blog.gclxry.com/chromium-framework-start/）。...在委托模式中，有两个对象参与处理同一个请求，接受请求的对象将请求委托给另一个对象来处理。委托模式是一项基本技巧，许多其他的模式，如状态模式、策略模式、访问者模式本质上是在更特殊的场合采用了委托模式。...Delegate的使用使得自动化测试也非常容易，这些测试需要能直接检测Chromium中的某个特性或功能能不能正常工作，检查新添加的代码对原有的代码有没有影响，但是由于有些功能需要手动干预才能正常工作，...比如下载模块中弹出的对话框需要手动选择保存文件的地址和文件名；这些会给自动测试代码带来麻烦，但是有了delegate的设计，我们在测试代码中可以直接实现对应的Test的delegate，继承正常工作的delegate

2.4K6 0

Linux内核内幕：深入解析进程的结束过程

大家好，我是程栩，一个专注于性能的大厂程序员，分享包括但不限于计算机体系结构、性能优化、云原生的知识。引天下没有不散的宴席，有进程的创建就会有进程的消亡。...当进程调用exit的时候，就出触发进程的结束操作；而对于一些不会显式exit的程序，其可能隐式的进行退出。例如C语言编译器可能会在mian函数末尾加上exit函数来中介进程。...因为一个进程组中的所有进程都共享同一个信号处理器（sighand_struct）和信号结构体（signal_struct），因此在进程退出时需要同步整个进程组的退出状态。...而当真的时候，会调用exit_itimers释放掉进程的计时器相关内容，因为此时已经没有进程了。...exit_xx函数释放了诸如内存、文件、文件系统、线程、工作队列、perf_event事件、自动调度组、cgroup等资源。

4591 0

初学者必看Ajax的总结

破坏了程序的异常机制。无法用 URL 直接访问 ajax 应用场景场景 1. 数据验证场景 2. 按需取数据场景 3....readyState ：ajax 处理过程 0：请求未初始化（还没有调用 open() ）。...1：请求已经建立，但是还没有发送（还没有调用 send() ）。 2：请求已发送，正在处理中（通常现在可以从响应中获取内容头）。...注意：在远程请求时，所有的 POST 请求都将转为 GET 请求json:返回 JSON 数据jsonp:JSONP 格式，使用 jsonp 形式调用函数时，例如：myurl?call back=?.../调用本次 Ajax 请求时传递的 options 参数} success Function 请求成功后调用的回调函数，有两个参数(1)由服务器返回，并根据 dataTyppe 参数进行处理后的数据(2

2.6K4 0

点击加载更多

扫码

添加站长进交流群

领取专属 10元无门槛券

手把手带您无忧上云