Java EE 7 - Инъекция в Runnable/вызываемый объект

Question

Параллелизм Утилита (JSR 236) была введен в Java EE 7.

Есть ли способ, как привнести свои EJBs в Runnable/вызываемый объект?

В частности, я хочу что-то вроде этого:

EJB с бизнес-логикой

@LocalBean 
public class MyEjb { 
    public void doSomeStuff() { 
     ... do some stuff ... 
    } 
} 

работоспособной/вызываемым класс, где я хочу, чтобы ввести экземпляр MyEjb

public class MyTask implements Runnable { 
    @EJB 
    MyEjb myEjb; 

    @Override 
    public void run() { 
     ... 
     myEjb.doSomeStuff(); 
     ... 
    } 
} 

объекта, который начинается новый Задача

@Singleton 
@Startup 
@LocalBean 
public class MyTaskManager { 
    @Resource 
    ManagedExecutorService executor; 

    @PostConstruct 
    void init() { 
     executor.submit(new MyTask()); 
    } 
} 

Поле myEjb в MyTask всегда равно null. Полагаю, что может помочь JNDI-поиск, но есть ли способ, как это сделать?

Answer 1

Вы должны дать контейнеру возможность впрыскивать EJB в экземпляр задач. Вы можете сделать это с помощью динамического экземпляра, как в этом коде:

@Stateless 
public class MyBean { 
    @Resource 
    ManagedExecutorService managedExecutorService; 
    @PersistenceContext 
    EntityManager entityManager; 
    @Inject 
    Instance<MyTask> myTaskInstance; 

    public void executeAsync() throws ExecutionException, InterruptedException { 
    for(int i=0; i<10; i++) { 
     MyTask myTask = myTaskInstance.get(); 
     this.managedExecutorService.submit(myTask); 
    } 
} 

Потому что вы не создать экземпляр с новым оператором, а по механизму экземпляра CDI, контейнер готовит каждый экземпляр MyTask при вызове myTaskInstance.get() ,

Answer 2

EJB нельзя вставить, если экземпляр MyTask создан вами, потому что Контейнер знает только созданные экземпляры. Вместо этого вы можете вводить EJB в MyTaskManager Singleton SB и определить свой MyTask Runnable класс как InnerClass следующим образом:

@Singleton 
@Startup 
@LocalBean 
public class MyTaskManager { 
    @Resource 
    ManagedExecutorService executor; 

    @EJB 
    MyEjb myEjb; 

    @PostConstruct 
    void init() { 
     executor.submit(new MyTask()); 
    } 

    class MyTask implements Runnable { 
     @Override 
     public void run() { 
      ... 
      myEjb.doSomeStuff(); 
      ... 
     } 
    } 
}