Skip to main content
Tweeted twitter.com/StackOverflowPT/status/1021291299322941440
Titulo editado.
Link
ramaral
  • 44,7mil
  • 14
  • 60
  • 110

Como fazer com que o "Executors" crieum ScheduledExecutorService lançar uma nova threadtarefa enquanto a ultimaanterior ainda não terminou de rodar?

Fonte Link
user94991
  • 249
  • 1
  • 4
  • 22

Como fazer com que o "Executors" crie uma nova thread enquanto a ultima ainda não terminou de rodar?

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.