multithreading - 如何从 ScalaFX 线程中获取值？

Question

我有一个 myNode: scalafx.scene.Node我想把它变成一个位图，以便我可以将它保存到磁盘，将它与其他位图进行比较等。我认为正确的代码将它变成 scalafx.scene.image.WritableImage是

val writableImg = new Scene { root = new Group(myNode) }.snapshot(null)

然后我应该可以把它变成 java.awt.image.RenderedImage和

val renderedImg = SwingFXUtils.fromFXImage(writableImg, null)

您可能已经意识到，问题是我必须运行代码才能获得 wrImg在 ScalaFX 线程上。有问题here这解释了如何返回一个值，但我没有任何运气将它翻译成 Scala。我试过这个:

lazy val writableImg: WritableImage = {
  val wrImg = new FutureTask(new Callable[WritableImage]() {
    override def call(): WritableImage = {
      new Scene { root = new Group(myNode) }.snapshot(null)
    }
  })
  Platform.runLater(wrImg)
  wrImg.get()
}

但代码只是挂起并且永远不会完成。谁能提供一个惯用的 Scala 版本和/或告诉我为什么代码永远不会返回？

Answer 1

如果您只想将图像保存到磁盘，您可以简单地在同一个线程上执行，避免传递图像的复杂性。像这样的东西会起作用:

Platform.runLater {
  val node = new Circle {
    centerX = 200
    centerY = 200
    radius = 50
    stroke = Color.BROWN
    strokeWidth = 2
    fill = Color.DARKKHAKI
  }
  val jfxImage = node.snapshot(new SnapshotParameters(), null)
  val bufferedImage = SwingFXUtils.fromFXImage(jfxImage, null)
  val file = new File("./snapshot.png")
  println("Writing snapshot to: " + file.getAbsolutePath)
  javax.imageio.ImageIO.write(bufferedImage, "png", file)
  ()
}

空()有闭包返回单元，所以 ScalaFX Platform.runLater很高兴。

更新 :

如果您想获得 Platform.runLater 中的值您在问题中建议的方法通常应该没问题。但是，您要确保不阻塞 FX 应用程序线程。如果您调用Platform.runLater在 FX 应用程序线程上你将被锁定，所以你可能想要这样的东西

def makeSnapshot() = myNode.snapshot(new SnapshotParameters(), null)

val writableImg = if (Platform.isFxApplicationThread) {
  makeSnapshot()
} else {
  val futureTask = new FutureTask(new Callable[WritableImage]() {
    override def call(): WritableImage = makeSnapshot()
  })
  Platform.runLater(futureTask)
  futureTask.get()
}