Служба исполнителя: SingleThreadExecutor не запускает работающий объект - PullRequest
Новая
       16

Служба исполнителя: SingleThreadExecutor не запускает работающий объект

0 голосов
/ 24 апреля 2019

Я пытаюсь выполнить работающий объект, используя пакет параллелизма Java, ExecutorService SingleThreadExecutor. Когда я вызываю команду execute для нового объекта Runnable, он просто переступает через него. то есть метод run () не вызывается.

Я прошел через строки кода с помощью отладчика и вижу, что мой SingleThreadExecutor был создан и мой Runnable инициализирован. 

public class RunnableDemo {

    public ExecutorService executor;

    public RunnableDemo () {
        this.executor = Executors.newSingleThreadExecutor();
    }

    public void start(){
       executor.execute(new MyRunnable("Hello World"));
    }

   public static void main(String[] args){
        RunnableDemo app = new RunnableDemo();
        app.start();
    }
}

public class MyRunnable implements Runnable {
   private String strToPrint;

   public MyRunnable(String parameter) {
       this.strToPrint = parameter;
   }

   public void run() {
      System.out.println(strToPrint);
   }
}

И, вероятно, говорит само за себя, но в этом сценарии я бы ожидал увидеть на экране "Hello World". Однако метод execute / run, по-видимому, не вызывается после создания runnable.

1 Ответ

0 голосов
/ 24 апреля 2019

Ваша программа завершает работу до того, как исполнитель запускает задачу.

Вы должны дождаться, пока исполнитель завершит работу следующим образом: 

public class RunnableDemo {

public ExecutorService executor;

public RunnableDemo () {
    this.executor = Executors.newSingleThreadExecutor();
}

public void start(){
   executor.execute(new MyRunnable("Hello World"));
}

public void awaitTermination(){
  try {
        service.awaitTermination(10, TimeUnit.SECONDS);
    } catch (InterruptedException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
}

public static void main(String[] args){
    RunnableDemo app = new RunnableDemo();
    app.start();
    app.awaitTermination();
}
}

public class MyRunnable implements Runnable {
private String strToPrint;

public MyRunnable(String parameter) {
   this.strToPrint = parameter;
}

public void run() {
  System.out.println(strToPrint);
}
}
...