/*
    * Logback: the reliable, generic, fast and flexible logging framework.
    * Copyright (C) 1999-2024, QOS.ch. All rights reserved.
    *
    * This program and the accompanying materials are dual-licensed under
    * either the terms of the Eclipse Public License v1.0 as published by
    * the Eclipse Foundation
    *
    *   or (per the licensee's choosing)
   *
   * under the terms of the GNU Lesser General Public License version 2.1
   * as published by the Free Software Foundation.
   */
  
  package ch.qos.logback.core.issue.lbcore258;
  
  import ch.qos.logback.core.CoreConstants;
  
  import java.util.concurrent.*;
  import java.util.zip.Deflater;
  
  public class Issues877 {
  
      static long START_TIME = System.currentTimeMillis();
  
      static class MyRunnable implements Runnable {
  
          final int id;
  
          MyRunnable(int id) {
              this.id = id;
          }
  
          long relativeTime() {
              return System.currentTimeMillis()-START_TIME;
          }
  
          @Override
          public void run() {
              try {
                  System.out.println("---------"+id+" "+Thread.currentThread().getName());
                  System.out.println(relativeTime()+ " starting my runnable"+id);
                  Thread.sleep(1_000);
                  System.out.println(relativeTime()+" exiting my runnable"+id);
              } catch (InterruptedException e) {
                  throw new RuntimeException(e);
              }
          }
      };
  
      public static void main(String[] args) throws InterruptedException {
  
          int corePoolSize = 2;
          int maximumPoolSize = 4;
  
          //ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(corePoolSize, maximumPoolSize, 0L,
            //        TimeUnit.MILLISECONDS, new SynchronousQueue<Runnable>());
  
          ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(corePoolSize, maximumPoolSize, 10L,
                       TimeUnit.MILLISECONDS, new LinkedBlockingQueue<>());
          threadPoolExecutor.allowCoreThreadTimeOut(true);
  
  
          submit(0, threadPoolExecutor);
  
          Thread.sleep(200);
          submit(1, threadPoolExecutor);
  
          Deflater deflater = new Deflater();
  
          System.out.println("exit");
  
          Thread.sleep(200);
          if(1==1)
              return;
  
          for(int i = 0; i < 8; i++) {
              submit(i, threadPoolExecutor);
          }
  
      }
  
      private static void submit(int i, ThreadPoolExecutor threadPoolExecutor) {
          MyRunnable myRunnable = new MyRunnable(i);
          System.out.println("submitting "+ i);
          threadPoolExecutor.submit(myRunnable);
      }
  }