package org.woehlke.computer.kurzweil.tabs.randomwalk.control;
   
   import lombok.Getter;
   import lombok.extern.java.Log;
   import org.woehlke.computer.kurzweil.commons.tabs.TabController;
   import org.woehlke.computer.kurzweil.tabs.randomwalk.config.RandomWalk;
   import org.woehlke.computer.kurzweil.tabs.randomwalk.config.RandomWalkContext;
   
   /**
   * Cyclic Cellular Automaton.
   * <p>
   * (C) 2006 - 2013 Thomas Woehlke.
   * http://thomas-woehlke.de/p/cyclic-cellular-automaton/
   *
   * @author Thomas Woehlke
   * <p>
   * Date: 05.02.2006
   * Time: 00:36:20
   */
  @Log
  @Getter
  /**
   * https://docs.oracle.com/en/java/javase/13/docs/api/java.base/java/util/concurrent/ThreadPoolExecutor.html
   * https://docs.oracle.com/en/java/javase/13/docs/api/java.base/java/util/concurrent/Executor.html
   * TODO: https://github.com/Computer-Kurzweil/computer_kurzweil/issues/18
   * TODO: https://github.com/Computer-Kurzweil/computer_kurzweil/issues/19
   * http://openbook.rheinwerk-verlag.de/javainsel9/javainsel_14_004.htm
   */
  public class RandomWalkController extends Thread implements TabController, RandomWalk {
  
      private static final long serialVersionUID = 7526471155622776147L;
  
      private final RandomWalkContext tabCtx;
      private final int threadSleepTime;
  
      private Boolean goOn;
  
      public RandomWalkController(
          RandomWalkContext tabCtx
      ) {
          super("Random Walk-Controller");
          this.tabCtx = tabCtx;
          this.goOn = Boolean.TRUE;
          this.threadSleepTime = tabCtx.getCtx().getProperties().getRandomwalk().getControl().getThreadSleepTime();
          ;
      }
  
      public void run() {
          //log.info("run() - begin");
          boolean doIt;
          do {
              synchronized (this.goOn) {
                  doIt = goOn.booleanValue();
              }
              synchronized (this.tabCtx) {
                  //log.info("running");
                  this.tabCtx.getTabModel().exec();
                  this.tabCtx.exec();
              }
              try {
                  super.sleep(this.threadSleepTime);
              } catch (InterruptedException e) {
                  log.info(e.getMessage());
              }
          }
          while (doIt);
          //log.info("run() - finished");
      }
  
      public void exit() {
          //log.info("exit");
          try {
              synchronized (goOn) {
                  goOn = Boolean.FALSE;
              }
              //log.info("join");
              join();
              //log.info("joined");
          } catch (InterruptedException e) {
              log.info(e.getMessage());
          }
          //log.info("exited");
      }
  
  }