Блог

Я хочу, чтобы «runnable» выполнялся со скоростью 5tps. Это выполняется не параллельно.

 package tt;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.DataInputStream;
import java.io.FileInputStream;
import java.io.FileWriter;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.URL;
import java.net.URLConnection;
import java.util.ArrayList;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import java.util.logging.Level;
import java.util.logging.Logger;

public class mySpawner {

public int tillDone = 0;
public int tillMax = 0;
public ArrayList arrayList;
private myWorker myworking;
private ScheduledExecutorService service = Executors.newScheduledThreadPool(50);

Runnable runnable = new Runnable() {

    @Override
    public void run() {
        try {
            System.out.println(System.nanoTime());
            Thread.sleep(7000);
        } catch (InterruptedException ex) {
            Logger.getLogger(mySpawner.class.getName()).log(Level.SEVERE, null, ex);
        }
    }
};


public void activate() {
    try {
        service = Executors.newScheduledThreadPool(50);
        service.scheduleAtFixedRate(runnable, 0, 200, TimeUnit.MILLISECONDS);
    } catch (Exception e) {//Catch exception if any
        System.err.println("Error: "   e.getMessage());
    }

}

public void deactivate() {
    service.shutdown();
}
  

}

Рассмотрим это:

• Ваши задачи находятся в спящем режиме в течение 7 секунд во время их выполнения
• Вы планируете новую задачу каждые 200 мс
• В вашем исполнителе всего 50 потоков

Я надеюсь, должно быть ясно, что у вас закончатся объединенные потоки всего через несколько секунд, и вы потеряете свой параллелизм. Вам нужно лучше сбалансировать это, либо снизив скорость, либо сократив время ожидания. Увеличение размера пула не поможет, у вас все равно закончатся потоки.

scheduleAtFixedRate создает только один поток, но выполняет runnable, предоставляемый с фиксированной скоростью.

• Действие выполняется за меньший промежуток времени, чем заданный период: в этом случае оно возобновляется точно через указанный период.
• Действие выполняется дольше (в вашем случае): действие немедленно запускается снова.

Если вы хотите добиться желаемого поведения, вы можете использовать следующий шаблон: просто запустите runnable один раз:

 service.schedule(runnable, 0, TimeUnit.MILLISECONDS);
  

но внутри run метода runnable добавьте следующий вызов с помощью

 service.schedule(runnable, 200, TimeUnit.MILLISECONDS);
  

Тем не менее рассмотрим арифметику, описанную в ответе скаффмана.

Обновление: Говард прав, мой первый пример был неправильным.

Я убедился, что это работает, если вы измените свой active() метод:

 service = Executors.newScheduledThreadPool(50);
new Thread() {
    public void run() {
        long nextTime = System.currentTimeMillis();
        while (true) {
            service.submit(runnable);
            long waitTime = nextTime - System.currentTimeMillis();
            Thread.sleep(Math.max(0, waitTime));
            nextTime  = 200;
        }
    }
}.start();