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