IllegalArgumentException одновременного ScheduledThreadPoolExecutor для scheduleAtFixedRate

Question

Я запускаю тестовый файл для HotSpot, JDK8 на моем Mac. Я использую IntelliJ IDEA для запуска этой Java-программы.

IntelliJ IDEA 2017.1.2
Build #IC-171.4249.39, built on April 25, 2017
JRE: 1.8.0_112-release-736-b16 x86_64
JVM: OpenJDK 64-Bit Server VM by JetBrains s.r.o
Mac OS X 10.12.5

---

Я получил ошибку, когда я установил frequency в Runner.java файл. Например, если я установлю 25,5 вместо 50 в следующем задании, я получу ошибки. Это почему?

int frequency = 50 * runSpecification.objectSize / runSpecification.allocationRatePerSecond; // 25 will fail and yield bug

Exception in thread "main" java.lang.IllegalArgumentException
    at java.util.concurrent.ScheduledThreadPoolExecutor.scheduleAtFixedRate(ScheduledThreadPoolExecutor.java:565)
    at eu.plumbr.gc.Runner.run(Runner.java:30)
    at eu.plumbr.gc.Runner.main(Runner.java:21)

Process finished with exit code 1

---

.
└── main
    └── java
        └── eu
            └── plumbr
                └── gc
                    ├── Consumer.java
                    ├── Producer.java
                    ├── RunSpecification.java
                    └── Runner.java

5 directories, 4 files

Consumer.java

package eu.plumbr.gc;

import java.util.Deque;

public class Consumer implements Runnable{

  private Deque<byte[]> deque;

  public Consumer(Deque<byte[]> deque) {
    this.deque = deque;
  }

  @Override
  public void run() {
    deque.poll();
  }
}

Producer.java

package eu.plumbr.gc;

import java.util.Deque;

public class Producer implements Runnable {

  private Deque<byte[]> deque;
  private int objectSize;

  public Producer(Deque<byte[]> deque, int objectSize) {
    this.deque = deque;
    this.objectSize = objectSize;
  }

  @Override
  public void run() {
    deque.add(new byte[objectSize]);
  }
}

Runner.java

package eu.plumbr.gc;

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

public class Runner {

  private RunSpecification runSpecification;
  private ScheduledExecutorService executorService;

  public Runner(RunSpecification runSpecification, ScheduledExecutorService executorService) {
    this.runSpecification = runSpecification;
    this.executorService = executorService;
  }


  public static void main(String[] args) throws InterruptedException {
    Runner runner = new Runner(new RunSpecification(10 * 1024, 1024 * 500, 5), Executors.newScheduledThreadPool(2));
    runner.run();
  }

  public void run() {
    ArrayDeque<byte[]> deque = new ArrayDeque<byte[]>();
    Producer producer = new Producer(deque, runSpecification.objectSize);
    Consumer consumer = new Consumer(deque);

    int frequency = 50 * runSpecification.objectSize / runSpecification.allocationRatePerSecond; // 25 will fail and yield bug
    executorService.scheduleAtFixedRate(producer, 0, frequency, TimeUnit.MILLISECONDS);
    executorService.scheduleAtFixedRate(consumer, 1000 * runSpecification.ttl, frequency, TimeUnit.MILLISECONDS);
  }
}

RunSpecification.java

package eu.plumbr.gc;

public class RunSpecification {
  public int objectSize;
  public int allocationRatePerSecond;
  public int ttl;

  public RunSpecification(int objectSize, int allocationRatePerSecond, int ttl) {
    this.objectSize = objectSize;
    this.allocationRatePerSecond = allocationRatePerSecond;
    this.ttl = ttl;
  }
}

Ссылка:

https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ScheduledExecutorService.html

Answer 1

Если вы прочитаете Javadocs, вы увидите

IllegalArgumentException - если период меньше или равен нулю

Не зная вашего точного вклада, но я бы сказал, что с

int frequency = 50 * runSpecification.objectSize / 
                      runSpecification.allocationRatePerSecond;

frequency больше 0, но с использованием 25 это не

Помните, что вы делаете целочисленное деление, и это можно проверить

    int objectSize = 10240; 
    int allocationRatePerSecond = 512000;

    System.out.println(50 * objectSize / allocationRatePerSecond);
    System.out.println(25 * objectSize / allocationRatePerSecond);

выход

1
0

Answer 2

На основе решения, предложенного "Scary Wombat", я внес изменения и избавился от ошибки. т.е. IllegalArgumentException - если период меньше или равен нулю

Исходный код:

private ScheduledExecutorService executor = Executors.newScheduledThreadPool(1);
executor.scheduleAtFixedRate(this, 0, 1, TimeUnit.valueOf(DAYS));

Исправленный код:

private ScheduledExecutorService executor = Executors.newScheduledThreadPool(1);
executor.scheduleAtFixedRate(this, 1, 1, TimeUnit.valueOf(DAYS));

Изменил второй параметр с 0 на 1, и все заработало!!