我有一段代码,它是对scaladoc for tasklocal中给出的代码片段的一个轻微修改[原文如下:https://monix.io/api/3.0/monix/eval/tasklocal.html ].
我的代码只是将内联任务(在for construction中)替换为对在for construction范围外定义的任务的引用。不幸的是,当我的任务运行时,它没有看到绑定,而是看到原始值(0)。我希望我稍加修改的代码(如下)能产生与scaladoc代码片段相同的结果。但出乎意料的是,我得到的是“值3:4”,而不是值3:200。我对tlocal的引用似乎得到了一个不同的threadish局部变量的“版本”,该变量初始化为默认值,对绑定一无所知。
代码
class MonixTests extends FlatSpecLike with Matchers {
"TaskLocal" should "not make me sad " in {
val tlocal: Task[TaskLocal[Int]] = TaskLocal(0)
val readTask: Task[Int] =
tlocal.flatMap {
taskLocal: TaskLocal[Int] =>
taskLocal.read.map{ i => i * 2 }
}
val task: Task[Unit] =
for {
local <- tlocal
value1 <- local.read // value1 == 0
_ <- local.write(100)
value2 <- local.read // value2 == 100
value3 <- local.bind(200)(readTask)
value4 <- local.read // value4 == 100
_ <- local.clear
value5 <- local.read // value5 == 0
} yield {
// Should print 0, 100, 400, 100, 0 -- but value3 is not 400, but 4
println("value1: " + value1)
println("value2: " + value2)
println("value3: " + value3)
println("value4: " + value4)
println("value5: " + value5)
}
import monix.execution.Scheduler.Implicits.global
implicit val opts = Task.defaultOptions.enableLocalContextPropagation
task.runToFutureOpt
println(" TRY AGAIN a slightly different way, but no success ;^( ")
val task3: Task[Unit] =
for {
local <- tlocal
value1 <- local.read // value1 == 0
_ <- local.write(100)
value2 <- local.read // value2 == 100
value3 <- local.bind(200)(readTask)
value44 <- local.bind(200) (
tlocal.flatMap {
taskLocal: TaskLocal[Int] =>
taskLocal.read.map{i => i * 2}
}
)
_ <- local.clear
value5 <- local.read // value5 == 0
} yield {
// Should print 0, 100, 400, 100, 0 -- but value3 is not 400, but 4
println("value1: " + value1)
println("value2: " + value2)
println("value3: " + value3)
println("value4: " + value44)
println("value5: " + value5)
}
task3.runToFutureOpt
}
理论基础:
我之所以要这样做是因为我想将一个值绑定到我的线程本地,然后创建一个任务的Map链,其中一些任务提取线程本地的当前值,我知道它是由tasklocal“前置”的。而且,为了清楚起见,其中一些任务是在我的代码库的其他类中定义的,而不是内联在任何特定的理解范围内。
谢谢/克里斯
1条答案
按热度按时间rmbxnbpk1#
我现在很高兴,因为我知道了如何或多或少地做我想做的事。下面的解决方案使用直接向上的“local”而不是tasklocal。但它具有所需的效果,即绑定值(200)在引用线程局部变量“tlocal”的代码块中可见。
我真的不需要在“任务上下文”中做什么,所以这让我走上了正确的轨道。