Service.restart（）生成大量不需要的线程数

Question

当用户输入TextField时：我需要通过WebRequest搜索一些数据并显示它们。

当用户输入多个字符时，应取消上一次下载，并开始新的下载。

所以我使用一个任务下载数据和一个服务来显示数据，当任务返回它们时。

s = new Service(){ 
    @Override 
    protected Task createTask() { 
     return new Task<String>(){ 
      @Override 
      protected String call() throws Exception { 
       //DOWNLOAD DATA 
       System.out.println("1"); 
       Thread.sleep(1000); 
       System.out.println("2"); 
       Thread.sleep(1000); 
       System.out.println("3"); 
       Thread.sleep(1000); 
       return "banana"; 
      } 
     }; 
    } 
}; 
s.setOnSucceeded(new EventHandler<WorkerStateEvent>(){ 
    @Override 
    public void handle(WorkerStateEvent event) { 
     System.out.println(event.getSource().getValue() + " DISPLAYED"); 
    } 
}); 

//HANDLE KEY RELEASED ON A TEXTFIELD 
public void onTextFieldKeyReleased() { 
    s.restart(); 
} 

我注意到，每次服务重新启动时，都会出现另一个线程，直到出现一定数量的线程。 这使程序显示数据的时间很长。

当KeyReleasedEvent发生时，我希望服务执行的操作是取消当前正在运行的任务并开始一个新任务...每次新任务时都不会追加任务。

我该如何做到这一点？

Answer 1

我无法重现您提到的延迟。

由于documented，Service使用“某些默认执行程序”来执行由createTask方法创建的Task。您可以配置执行，如果你想修改默认的行为，例如：

s.setExecutor(Executors.newCachedThreadPool(runnable -> { 
    Thread t = new Thread(runnable); 
    t.setDaemon(true); 
    return t ; 
}); 

很明显，你可以请根据您的具体要求（这并不完全清楚你的问题），你选择的任何遗嘱执行人。例如，如果你想限制（说）5线程，你可以做

s.setExecutor(Executors.newFixedThreadPool(5, runnable -> { 
    Thread t = new Thread(runnable); 
    t.setDaemon(true); 
    return t ; 
}); 

这是一个SSCCE。我加了一些记录到跟踪服务的状态，并显示该线程正在使用的任务：

import java.util.concurrent.Executors; 

import javafx.application.Application; 
import javafx.concurrent.Service; 
import javafx.concurrent.Task; 
import javafx.scene.Scene; 
import javafx.scene.control.TextField; 
import javafx.scene.layout.StackPane; 
import javafx.stage.Stage; 

public class ServiceRestartTest extends Application { 

    @Override 
    public void start(Stage primaryStage) { 
     Service<Void> s = new Service<Void>(){ 
      @Override 
      protected Task<Void> createTask() { 
       return new Task<Void>(){ 
        @Override 
        protected Void call() throws Exception { 
         //DOWNLOAD DATA 
         System.out.println("New task on thread "+Thread.currentThread()); 
         System.out.println("1"); 
         Thread.sleep(1000); 
         System.out.println("2"); 
         Thread.sleep(1000); 
         System.out.println("3"); 
         Thread.sleep(1000); 
         return null; 
        } 
       }; 
      } 
     }; 
     s.setExecutor(Executors.newCachedThreadPool(runnable -> { 
      Thread t = new Thread(runnable); 
      t.setDaemon(true); 
      return t; 
     })); 

     s.stateProperty().addListener((obs, oldState, newState) -> System.out.println(newState)); 

     TextField textField = new TextField(); 
     textField.setOnKeyReleased(e -> s.restart()); 

     primaryStage.setScene(new Scene(new StackPane(textField), 350, 120)); 
     primaryStage.show(); 

    } 

    public static void main(String[] args) { 
     launch(args); 
    } 
} 

输出，只显示两个线程使用：

 
SCHEDULED 
New task on thread Thread[Thread-5,5,main] 
1 
RUNNING 
CANCELLED 
READY 
SCHEDULED 
New task on thread Thread[Thread-6,5,main] 
1 
RUNNING 
CANCELLED 
READY 
SCHEDULED 
New task on thread Thread[Thread-6,5,main] 
1 
RUNNING 
CANCELLED 
READY 
SCHEDULED 
New task on thread Thread[Thread-6,5,main] 
1 
RUNNING 
CANCELLED 
READY 
SCHEDULED 
New task on thread Thread[Thread-6,5,main] 
1 
RUNNING 
CANCELLED 
READY 
SCHEDULED 
New task on thread Thread[Thread-6,5,main] 
1 
RUNNING 
2 
3 
SUCCEEDED