首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

Vertx中的协程从不执行?

Vertx中的协程从不执行是因为协程并不是默认启用的,需要使用特定的方式来调用和执行。

协程是一种轻量级的线程或者称为轻量级的任务,可以在不创建额外线程的情况下实现并发编程。在Vertx中,协程是使用Kotlin语言中的kotlinx.coroutines库实现的。

要在Vertx中启用协程,需要在项目中添加vertx-lang-kotlin-coroutines的依赖。这个依赖包含了使用协程的相关扩展和工具。

在使用Vertx的协程之前,需要先创建一个CoroutineScope对象,它代表了协程的作用域。协程必须在作用域中才能执行。可以使用CoroutineScope.vertx(vertx)来创建一个基于Vertx的作用域。

然后,可以使用launch函数来定义和执行协程。launch函数可以接受一个suspend修饰的挂起函数或者一个lambda表达式作为参数。这个函数或者表达式会在协程中执行。

以下是一个使用Vertx协程的示例代码:

代码语言:txt
复制
import io.vertx.kotlin.coroutines.CoroutineVerticle
import io.vertx.kotlin.coroutines.awaitResult
import io.vertx.kotlin.coroutines.launch

class MyVerticle : CoroutineVerticle() {
    override suspend fun start() {
        val result = awaitResult<String> { handler ->
            vertx.eventBus().send("some-address", "some-message", handler)
        }
        println("Received result: $result")
    }
}

val vertx = Vertx.vertx()
val verticle = MyVerticle()
val scope = CoroutineScope.vertx(vertx)

scope.launch {
    vertx.deployVerticleAwait(verticle)
    println("Verticle deployed")
}

在上述示例中,MyVerticle类继承了CoroutineVerticle类,使其能够在协程中执行。start函数中的代码会在协程中被执行。

在协程中,可以使用awaitResult函数来等待异步操作的结果。在上述示例中,使用awaitResult等待事件总线发送消息的结果,并将结果打印出来。

最后,使用CoroutineScopelaunch函数来启动协程。在协程中,调用deployVerticleAwait函数来部署MyVerticle

需要注意的是,在使用Vertx的协程时,要确保相关的依赖已经正确添加到项目中,并且代码在协程作用域中执行。

页面内容是否对你有帮助?
有帮助
没帮助

相关·内容

及Python

1 1.1概念 ,又称微线程,纤。英文名Coroutine。一句话说明什么是线程:是一种用户态轻量级线程。...我们把一个线程一个个函数叫做子程序,那么子程序在执行过程可以中断去执行别的子程序;别的子程序也可以中断回来继续执行之前子程序,这就是。...1.2 优缺点 优点:   (1)无需线程上下文切换开销,避免了无意义调度,由此可以提高性能(但也因此,程序员必须自己承担调度责任,同时,也失去了标准线程使用多CPU能力)...(2)进行阻塞(Blocking)操作(如IO时)会阻塞掉整个程序 2 Python如何实现 2.1 yield实现   前文所述“子程序(函数)在执行过程可以中断去执行别的子程序;别的子程序也可以中断回来继续执行之前子程序...2.2 greenlet实现   Python greenlet就相当于手动切换,去执行别的子程序,在“别的子程序”又主动切换回来。。。 greenlet例子: 1 #!

1.3K20

【Kotlin 启动 ③ ( 组合并发 | 挂起函数串行执行 | 组合并发执行挂起函数 )

文章目录 一、挂起函数串行执行 二、组合并发执行挂起函数 一、挂起函数串行执行 ---- 在 , 连续使用多个挂起函数 , 这些函数执行是顺序执行 , 挂起函数 1 执行完毕后 , 才执行...setContentView(R.layout.activity_main) runBlocking { // 调用 runBlocking 函数 , 可以将 主线程 包装成 ...: 最终执行结果为 577 ms , 00:14:00.962 I 两个返回值相加 3 00:14:00.963 I 挂起函数执行耗时 577 ms 二、组合并发执行挂起函数 ----...如果想要两个挂起函数并发执行 , 并且同时需要两个函数返回值 , 则使用 async 构建器 , 启动两个协 , 在执行两个并发函数 ; 代码示例 : package kim.hsl.coroutine...: 启动两个 async , 并发执行两个挂起函数 , 耗时 355 ms , 达到了并发执行减少执行时间目的 ; 00:18:50.081 I 两个返回值相加 3 00:18:50.081

69220
  • 【Kotlin 启动 ② ( 多程控制 | launch 执行顺序控制 | Job#join() 函数 | async 执行顺序控制 | Deferred#await() 函数 )

    87183425 一、launch 执行顺序控制 ---- 如果需要通过 launch 构建器 启动多个协 , 后面的需要等待前面的执行完毕 , 在启动靠后 , 实现方案如下 :...调用 Job#join() 函数 , 可以挂起 , 等待 launch 体内任务执行完毕 , 再执行后面的任务 ; 代码示例 : 下面的代码 , 先执行 launchJob ,...* * 这个挂起函数是可取消,并且**总是**检查是否取消了调用Job。..., 在启动靠后 , 实现方案如下 : 调用 Deferred#await() 函数 , 可以挂起 , 等待 async 体内任务执行完毕 , 再执行后面的任务 ; 代码示例 :...下面的代码 , 先执行 asyncDeferred , 调用 asyncDeferred.await() 函数会挂起 , 该 asyncDeferred 任务执行完毕后 , 才会执行后面的

    97820

    java框架quasar和kotlin

    接下来要分享这个开源项目,正是解决了在java只能使用多线程模型开发高并发应用窘境,使得java也能像Go语言那样使用语义开发了。...\quasar-core\0.7.10\quasar-core-0.7.10.jar 线程VS 下面模拟调用某个远程服务,假设远程服务处理耗时需要1S,这里使用执行阻塞1S来模拟,分别看多线程模型和协模型调用这个服务...而反观,基于固定几个线程调度,可以轻松实现百万级处理,而且内存稳稳。 后记 最后,博主以为Quasar只是一个框架层面的东西,所以就又去看了下同样是jvm语言kotlin。...,有种震惊赶脚,kotlin同步模型牛逼呀,瞬时感觉到发现了java里骚操作了,可以使用kotlin来代替java多线程操作。...io操作,io操作是阻塞并发也就变成了调度几个线程并发了。

    47830

    【Kotlin 取消 ③ ( finally 释放资源 | 使用 use 函数执行 Closeable 对象释放资源操作 | 构造无法取消任务 | 构造超时取消任务 )

    函数构造超时取消任务 一、释放资源 ---- 如果 中途取消 , 期间需要 释放占有的资源 ; 如果执行任务 , 需要 执行 关闭文件 , 输入输出流 等操作 , 推荐使用...try…catch…finally 代码块 , 在 finally 代码块代码 , 即使是取消时 , 也会执行 ; 代码示例 : package kim.hsl.coroutine import...") } } } 执行结果 : 即使是取消协任务后 , 在抛出 JobCancellationException 异常后 , finally 代码在最后也被执行了 ;...(1000) Log.i(TAG, "释放占用资源完毕") } } 如果在取消后 , finally 代码块代码肯定会执行 , 但是如果 finally delay...挂起函数以及之后代码将不会被执行 ; 使用 withContext(NonCancellable) {} 代码块 , 可以构造一个无法取消任务 , 这样可以避免 finally 代码无法完全执行

    1.3K10

    Golang(goroutine)

    进程         进程就是程序在操作系统一次执行过程,是系统进行资源分配和调度基本单位,进程是一个动态概念,是程序在执行过程中分配和管理资源基本单位,每一个进程都有一个自己地址空间。...一个进程可以创建多个线程,同一个进程多个线程可以并发执行,一个程序要运行的话至少有一个进程。...Go 语言中是由 Go 运行时调度器(scheduler)进行管理和调度。当程序启动时,Go 运行时会默认启动一个主,主会创建其他,这些会被分配到不同系统线程上进行执行。...-1 } func main() { //注意:     //1.主线程执行完毕后即使没有执行完毕程序也会退出     //2.可以在主线程没有执行完毕前提前退出,是否执行完毕不会影响主线程执行...} 多和多线程         Golang每个goroutine()默认占用内存比Java、C线程少。

    60140

    Kotlin-特殊阻塞

    阻塞是种特殊启动方式,一般是用 runBlocking{} 扩起来一段。...首先是父得到执行,然后才是子。 重点是这两段都在同一个线程main里完成。这里就带来一个有趣问题, runBLocking{}和平时常用launch有什么区别?...但实际情况跟注释有点不同,如果在 runBlocking 开一个 GlobalScope.launch,并且在里面延时很久,那么外面的线程其实是不会等待 GlobalScope 里完成。...在创建完coroutine后就进入派发流程了,这部分和Kotlin-一个生命周期中逻辑比较相似,下面也会讲到。...这个问说明,runBLocking{}这种,它运行逻辑是先把父放队列里,然后取出来执行执行完毕再把子入队,再出队子,用同样方式递归。

    2.4K20

    python与golang

    它被包含在进程之中,是进程实际运作单位。 进程和线程关系: 一条线程指的是进程中一个单一顺序控制流,一个进程可以并发多个线程,每条线程并行执行不同任务。...和大多数语言一样,在 Python 调度是非抢占式,也就是说一个必须主动让出执行机会,其他才有机会运行。 让出执行关键字就是 await。...goroutine 是一种 比线程更加轻盈、更省资源。 Go 语言通过系统线程来多路派遣这些函数执行,使得 每个用 go 关键字执行函数可以运行成为一个单位。...当一个阻塞时候,调度器就会自 动把其他安排到另外线程中去执行,从而实现了程序无等待并行化运行。...---- 某书 4种状态 Pending Running Done Cacelled 和系统线程之间映射关系 go本质上还是系统线程调用,而Python是eventloop模型实现

    1.5K20

    unity update _Unity 原理

    Unity 原理 发布时间:2019-06-13 18:45, 不是多线程,还是在主线程里面(注:在Unity中非主线程是不可以访问Unity资源) 1、线程、进程和协区别 进程有自己独立堆和栈...和线程区别是:避免了无意义调度,由此可以提高性能,但也因此,程序员必须自己承担调度责任,同时,也失了标准线程使用多CPU能力。...2、Unity执行原理 先贴上一张unity主线框架运行图: 在Unity运行时,调用就是开启了一个IEnumerator(迭代器),开始执行,在执行到yield return之前和其他正常程序没有差别...3、主要应用 不是只能做一些简单延迟,如果只是单纯暂停几秒然后在执行就完全没有必要开启一个线程。...这是我们就可以使用了,是每帧LateUpdate之前执行yield return 之前代码,LateUpdate之后执行yield return 之后代码(可以用过上面的小例子看出)。

    96910

    ”字是什么意思?

    Golang(coroutine)概念,其名字来源可以从两个方面来解释,一是历史背景,二是技术特性。 历史背景 (coroutine)这个概念最早可以追溯到计算机科学早期。...是一种程序组件,它允许不同入口点用于暂停和恢复执行,这种机制允许执行流在不同程之间切换,而不是传统函数调用方式。...在Golang被实现为“goroutine”,它是Go语言并发设计核心。Goroutine在使用和概念上与传统有所不同,但基本思想是相通。...这意味着一个运行会一直执行,直到它显式地表示要让出执行权(例如,通过等待I/O操作、显式挂起或调用其他等方式)。...这种方式优点是上下文切换开销小,因为切换发生时机是可预测,并且由自己控制。但缺点是,如果一个长时间占用CPU不主动让出执行权,会导致其他饿死,影响程序响应性。

    9500

    【Kotlin 挂起和恢复 ① ( 挂起和恢复概念 | suspend 挂起函数 )

    文章目录 一、挂起和恢复概念 二、 suspend 挂起函数 一、挂起和恢复概念 ---- 函数 最基本操作 是 : 调用 call : 通过 函数名或函数地址 调用函数 ; 返回...return : 函数执行完毕后 , 继续执行函数调用下一行代码 ; 在 调用 call 和 返回 return 基础上 , 又新增了两种 状态 : 挂起 Suspend : 暂停当前执行..., 在子线程执行异步任务后 , 会马上执行后续代码 , 只是相当于 普通多线程操作 ; 作用就是 可以 顺序地执行 异步任务 和 主线程任务 , 其执行顺序按照代码顺序执行 ; 挂起 函数..., 只能在 体内部 或者 其它挂起函数 调用 ; 外部不允许使用挂起函数 ; 在 , 执行 挂起 Suspend 函数 , 将 挂起点信息 记录下来 , 然后执行耗时操作 , 执行完毕后...){} , 可以直接调用挂起函数 ; 挂起 函数 , 只能在 体内部 或者 其它挂起函数 调用 ; 外部不允许使用挂起函数 ; 在 , 执行 挂起 Suspend 函数 , 将 挂起点信息

    1.6K40

    揭秘kotlinCoroutineContext

    ,这些可以在同一线程不同时刻被执行,也可以在不同线程上不同时刻被执行。...(Cancelling)状态, 处于取消状态会等所有子都完成后才进入取消 (Cancelled)状态,当执行完成后或者调用CompletableJob(CompletableJob是Job...Dispatchers.Unconfined,所以第一次执行时是由启动线程执行,上面在主线程启动了,所以第一次输出主线程main,withContext方法是一个suspend方法,它可以挂起当前...-1,第一个代码块执行完毕后,在DefaultDispatcher-worker-1线程恢复,所以恢复后执行在DefaultDispatcher-worker-1线程,所以第三次继续输出DefaultDispatcher-worker...最后一个元素, ContinuationInterceptor它也是继承自Element,通常叫做上下文拦截器,它主要作用是在执行前拦截它,从而在执行前做出一些其他操作,前面我们讲到

    1.9K30

    Java 库 - Quasar

    这就是适用场景。...,其实就是在一个线程,有一个总调度器,对于多个任务,同时只有一个任务在执行,但是一旦该任务进入阻塞状态,就将该任务设置为挂起,运行其他任务,在运行完或者挂起其他任务时候,再检查待运行或者挂起任务状态...方式更多用来做阻塞密集型(比如 I/O)操作,计算密集型还是使用线程更加合理。 Java 官方并没有库。但是伟大社区提供了一个优秀库,它就是 Quasar。...那么我们为什么称 Quasar 为库呢?...这里 Quasar 就是通过抛异常(SuspendExecution)方式来达到,这样就完成了以线程方式实现

    2.7K31

    【Kotlin 挂起和恢复 ② ( 挂起 和 线程阻塞 对比 )

    文章目录 一、挂起 和 线程阻塞 对比 1、挂起 2、线程阻塞 3、挂起和阻塞对 UI 影响 4、挂起分析 一、挂起 和 线程阻塞 对比 ---- 挂起是概念 , 只能在中使用...; 阻塞是线程概念 , 可以在主线程和子线程中使用 ; 1、挂起 挂起 操作 : 在中使用 delay 函数 , 挂起 20 秒时间 , 然后 20 秒后更新 UI ; delay... 挂起 操作 不会出现 阻塞 UI 刷新情况 , 挂起 20 秒不影响 UI 刷新显示 ; 但是如果将主线程阻塞 , UI 不再刷新 , 会出现 ANR 崩溃异常 ; 图形化 GUI 系统..., 一般都在主线程更新 UI , 主线程中都有一个无限循环 , 不断刷新界面 , 如果在主线程执行了耗时操作 , 就会影响到界面的刷新 , 出现漏帧 , ANR 崩溃异常 ; 4、挂起分析 中有挂起操作..., 会将挂起点状态保存 , 同时停止执行 , 等待挂起函数执行完毕后 , 继续执行 ; 相当于阻塞 , 不会阻塞主线程 ;

    1.7K20
    领券