Eu estou implementando um scheduler para rodar algumas threads no meu sistema em intervalos x de tempo. O grande problema é que se a thread 1 ainda não terminou de rodar, a 2 não começa, mesmo o seu tempo tendo chegado.
No exemplo abaixo eu "forcei" esse erro, pois estava desconfiado que isso poderia estar acontecendo.
Thread
package backgroundProcesses;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.TimerTask;
public class MinhaThread implements Runnable {
@Override
public void run() {
Calendar cal = Calendar.getInstance();
SimpleDateFormat sdf = new SimpleDateFormat("HH:mm:ss");
System.out.println("FOI, COMEÇOOU A THREAD: " + sdf.format(cal.getTime()));
int i = 0;
while(i < 1000000000) {
int a = 1;
}
System.out.println("CHEGOU AO FIM");
}
}
Executor
package backgroundProcesses;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import javax.servlet.annotation.WebListener;
@WebListener
public class ExecutorThreads implements ServletContextListener {
private ScheduledExecutorService scheduler;
@Override
public void contextInitialized(ServletContextEvent arg0) {
// TODO Auto-generated method stub
scheduler = Executors.newScheduledThreadPool(4);
scheduler.scheduleAtFixedRate(new MinhaThread(), 0, 10, TimeUnit.SECONDS);
}
@Override
public void contextDestroyed(ServletContextEvent arg0) {
// TODO Auto-generated method stub
scheduler.shutdownNow();
}
}
Estou rodando a aplicação em um simples TomCat, não uso TomcatEE.
Resultado Desejado:
Ao iniciar o programa, a primeira thread será criada. 10 segundos depois, apesar da primeira thread ainda estar no loop, a segunda thread também é criada e começa a rodar.