代码之家 › 专栏 › 技术社区 › Kumar Waghmode

在scala cats的后台线程上运行IO

scala-cats concurrency scala multithreading

Kumar Waghmode · 技术社区 · 5 年前

def backGroundTask:IO[Unit]={
IO
{
//Time consuming task
}
}

如何在后台线程上急切地执行这个任务?

1 回复 | 直到 5 年前

Krzysztof AtÅasik 5 年前

你可以使用 ContextShift.evalOn :

def backGroundTask = IO {
      Thread.currentThread()
}

val contextShift: ContextShift[IO] = IO.contextShift(ExecutionContext.global)

val ec = ExecutionContext.fromExecutor(Executors.newCachedThreadPool()) //create other execution context

println(backGroundTask.unsafeRunSync()) // will print Thread[main,5,main]
println(contextShift.evalOn(ec)(backGroundTask).unsafeRunSync()) //will print Thread[pool-1-thread-1,5,main]

推荐文章

Zdanovskiy Mihail · Numba使用parallel=True标志集使Python崩溃

1 年前

Ma Joonyoung · 粗粒度和细粒度链表的时间比较

1 年前

Community wiki · SqlConnections,Parallel.For,一个旧的C#应用程序,初始化SqlConnections时随机挂起

1 年前

user1700890 · 了解交互式代理Python API中的线程

2 年前

AntonBoarf · 为什么要将实例变量指定给局部变量?

2 年前

rhymes · 如何让线程操作相同的java列表

2 年前

Ben · 错误:缺少类型说明符-假定为int。注意C++不支持默认初始化

2 年前

SRK7Kyros · 在Python中启动线程时是否使用整个处理器线程?

2 年前

MatiiFine · 在c++[duplicate]中的主源文件外使用std::thread

2 年前

Youssof. K. · 线程1:vector insert上的EXC_BAD_访问(代码=1,地址=0x0)

2 年前