service - 如何在 JavaFX2 中的 Service 和 UI 之间通信用户定义的对象和异常？

Question

如何在 JavaFX2 中的 Service 和 UI 之间通信用户定义的对象和用户定义的(检查的)异常？这些示例仅显示字符串作为属性发送到服务，并将可观察字符串数组发送回 UI。

属性似乎只为简单类型定义。 StringProperty、IntegerProperty、DoubleProperty 等目前，我有一个用户定义的对象(不是简单类型)，我希望 Task 对其进行操作并使用它生成的输出数据进行更新。我通过 Service 的构造函数发送它，Service 的构造函数通过 Task 的构造函数传递它。我想知道参数必须通过属性传递的限制。另外，如果Task运行过程中抛出异常，它如何从Service传递到UI？我只看到了 getException() 方法，没有传统的 throw/catch。

属性 http://docs.oracle.com/javafx/2/binding/jfxpub-binding.htm

服务和任务 http://docs.oracle.com/javafx/2/threads/jfxpub-threads.htm

服务javadocs http://docs.oracle.com/javafx/2/api/javafx/concurrent/Service.html#getException ()

"Because the Task is designed for use with JavaFX GUI applications, it ensures that every change to its public properties, as well as change notifications for state, errors, and for event handlers, all occur on the main JavaFX application thread. Accessing these properties from a background thread (including the call() method) will result in runtime exceptions being raised.

It is strongly encouraged that all Tasks be initialized with immutable state upon which the Task will operate. This should be done by providing a Task constructor which takes the parameters necessary for execution of the Task. Immutable state makes it easy and safe to use from any thread and ensures correctness in the presence of multiple threads."

但是如果我的 UI 仅在任务完成后才接触对象，那么应该没问题，对吧？

Answer 1

服务有一个签名Service<V> <V>是一个通用类型参数，用于指定服务提供的任务的返回对象的类型。

假设您想要定义一个返回 Foo 类型的用户定义对象的服务，那么您可以这样做:

 class FooGenerator extends Service<Foo> {
   protected Task createTask() {
     return new Task<Foo>() {
       protected Foo call() throws Exception {
         return new Foo();
       }
     };
   }
 }

要使用该服务:

 FooGenerator fooGenerator = new FooGenerator();
 fooGenerator.setOnSucceeded(new EventHandler<WorkerStateEvent>() {
   @Override public void handle(WorkerStateEvent t) {
     Foo myNewFoo = fooGenerator.getValue();
     System.out.println(myNewFoo);
   }
 });
 fooGenerator.start();

<小时/>

如果您想在每次启动或重新启动服务之前将输入值传递到服务中，则必须更加小心。您可以将要输入到服务的值添加为服务上的可设置成员。在调用服务的 start 方法之前，可以从 JavaFX 应用程序线程调用这些 setter。然后，当创建服务的任务时，将参数传递给服务的任务的构造函数。

执行此操作时，最好使所有可在线程之间来回传递的信息不可变。对于下面的示例，Foo 对象作为输入参数传递给服务，并且基于作为服务输出接收的输入传递 Foo 对象。但 Foo 本身的状态仅在其构造函数中初始化 - Foo 的实例是不可变的，一旦创建就无法更改，并且它的所有成员变量都是最终的且无法更改。这使得推理程序变得更加容易，因为您永远不需要担心另一个线程可能会同时覆盖状态。看起来有点复杂，但确实让一切变得非常安全。

class FooModifier extends Service<Foo> {
  private Foo foo;
  void setFoo(Foo foo) { this.foo = foo; }

  @Override protected Task createTask() {
    return new FooModifierTask(foo);
  }

  private class FooModifierTask extends Task<Foo> {
    final private Foo fooInput;
    FooModifierTask(Foo fooInput) { this.fooInput = fooInput; }

    @Override protected Foo call() throws Exception {
      Thread.currentThread().sleep(1000);
      return new Foo(fooInput);
    }
  }
}

class Foo {
  private final int answer;
  Foo()          { answer = random.nextInt(100); }
  Foo(Foo input) { answer = input.getAnswer() + 42; }
  public int getAnswer() { return answer; }
}

还有一个向 Service 提供输入的示例在服务中javadoc .

<小时/>

要从服务返回自定义用户异常，只需在服务的任务调用处理程序期间抛出用户异常即可。例如:

 class BadFooGenerator extends Service<Foo> {
   @Override protected Task createTask() {
     return new Task<Foo>() {
       @Override protected Foo call() throws Exception {
         Thread.currentThread().sleep(1000);
         throw new BadFooException();
       }
     };
   }
 }

并且可以像这样检索异常:

 BadFooGenerator badFooGenerator = new BadFooGenerator();
 badFooGenerator.setOnFailed(new EventHandler<WorkerStateEvent>() {
   @Override public void handle(WorkerStateEvent t) {
     Throwable ouch = badFooGenerator.getException();
     System.out.println(ouch.getClass().getName() + " -> " + ouch.getMessage());
   }
 });
 badFooGenerator.start();

<小时/>

我创建了几个 executable samples您可以尝试一下。