Timer beendet nicht immer

[Fohnbit]

Hallo und frohe Weihnachten!

Ich habe einen Timer, denn ich starte, sich zyklisch wiederholt und auch wieder beenden muss.
Danach starte ich den Timer erneut:

	private void startPolling() {
	
		TimerTask action = new TimerTask() {

			public void run() {
				updateOutputDebug_str("Polling");
				updateOutputSerdata(bb.array());
			}
		};

		timerDelayer = new Timer();
		timerDelayer.schedule(action, 0, intervall);
	}

	private void stopPolling() {
		if (!(timerDelayer == null)) {
			timerDelayer.cancel();
			}
	}

Intervall ist 3000 Millisekunden.
Es kommt aber vor, das der Timer manchmal nicht beendet.

Ist an startPolling und stopPolling etwas falsch?

Vielen Dank!

 

[Fohnbit]

Nochmals Hallo!

Sieht so aus als habe ich die Start nochmal gestartet, als er schon lief und somit eine 2. Instanz geöffnet.

Aber warum beendet "timerDelayer.cancel()" nicht alle laufenden?

 

[Flown]

Besser wäre ein ExecutorService:

import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;

public class TimerManager {
  public static void main(String... args) {
    TimerManager tm = new TimerManager();
    tm.startPolling();
    try {
      Thread.sleep(10_000);
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
    tm.stopPolling();
    tm.startPolling();
    try {
      Thread.sleep(10_000);
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
    tm.stopPolling();
    
    tm.close();
  }
  
  private final ScheduledExecutorService executor;
  private ScheduledFuture<?> task;
  
  public TimerManager() {
    executor = Executors.newSingleThreadScheduledExecutor();
  }
  
  public void startPolling() {
    if (task == null) {
      task = executor.scheduleAtFixedRate(() -> System.out.println("Polling"), 0, 3_000, TimeUnit.MILLISECONDS);
    }
  }
  
  public void stopPolling() {
    if (task != null) {
      task.cancel(true);
      task = null;
    }
  }
  
  public void close() {
    stopPolling();
    executor.shutdownNow();
  }
}