我想用
scalaz.concurrent.Task 实现我的异步处理。我需要一个函数(Task[A], Task[B]) => Task[(A, B)] 来返回一个新任务，其工作方式如下：
Task[A]和Task[B]，等待结果；你会如何实现这样的功能？
【问题讨论】：
Nondeterminism 上的both 之类的东西就会起作用。如果您还想避免浪费循环（或者您想撤消仍在运行的计算的影响），它会更加复杂。
标签： scala concurrency task scalaz
正如我上面提到的，如果您不关心实际停止非失败计算，您可以使用Nondeterminism。例如：
import scalaz._, scalaz.Scalaz._, scalaz.concurrent._
def pairFailSlow[A, B](a: Task[A], b: Task[B]): Task[(A, B)] = a.tuple(b)
def pairFailFast[A, B](a: Task[A], b: Task[B]): Task[(A, B)] =
Nondeterminism[Task].both(a, b)
val divByZero: Task[Int] = Task(1 / 0)
val waitALongTime: Task[String] = Task {
Thread.sleep(10000)
println("foo")
"foo"
}
然后：
pairFailSlow(divByZero, waitALongTime).run // fails immediately
pairFailSlow(waitALongTime, divByZero).run // hangs while sleeping
pairFailFast(divByZero, waitALongTime).run // fails immediately
pairFailFast(waitALongTime, divByZero).run // fails immediately
除第一种情况外，waitALongTime 中的副作用都会发生。如果您想尝试停止该计算，则需要使用类似Task 的runAsyncInterruptibly。
【讨论】：
Java 开发人员中有一个奇怪的概念，即您不应该取消并行任务。他们使用Thread.stop() 并将其标记为已弃用。如果没有Thread.stop()，您将无法真正取消未来。您所能做的就是向未来发送一些信号，或者修改一些共享变量并在未来内部编写代码以定期检查它。因此，所有提供 future 的库都可以建议取消 future 的唯一方法：合作完成。
我现在面临同样的问题，正在为可能被取消的期货编写自己的库。有一些困难，但它们可能会得到解决。您只是不能在任意位置调用 Thread.stop() 。线程可以执行更新共享变量。锁会被正常调用，但更新可能会中途停止，例如仅更新 double 值的一半，依此类推。所以我要介绍一些锁。如果线程处于受保护状态，那么它现在应该被 Thread.stop() 杀死，但发送特定消息。守卫状态被认为总是非常快地等待。所有其他时间，在计算过程中，线程可能会被安全地停止并替换为新线程。
所以，答案是：你不应该想取消期货，否则你就是异端，Java 社区中没有人愿意伸出援手。您应该定义自己的可以杀死线程的执行上下文，并且您应该编写自己的期货库以在此上下文上运行
【讨论】：