Search code examples
jsfjakarta-eeconcurrencyejb

Is it safe to manually start a new thread in Java EE?


I could not find a definitive answer to whether it is safe to spawn threads within session-scoped JSF managed beans. The thread needs to call methods on the stateless EJB instance (that was dependency-injected to the managed bean).

The background is that we have a report that takes a long time to generate. This caused the HTTP request to time-out due to server settings we can't change. So the idea is to start a new thread and let it generate the report and to temporarily store it. In the meantime the JSF page shows a progress bar, polls the managed bean till the generation is complete and then makes a second request to download the stored report. This seems to work, but I would like to be sure what I'm doing is not a hack.


Solution

  • Introduction

    Spawning threads from within a session scoped managed bean is not necessarily a hack as long as it does the job you want. But spawning threads at its own needs to be done with extreme care. The code should not be written that way that a single user can for example spawn an unlimited amount of threads per session and/or that the threads continue running even after the session get destroyed. It would blow up your application sooner or later.

    The code needs to be written that way that you can ensure that an user can for example never spawn more than one background thread per session and that the thread is guaranteed to get interrupted whenever the session get destroyed. For multiple tasks within a session you need to queue the tasks. Also, all those threads should preferably be served by a common thread pool so that you can put a limit on the total amount of spawned threads at application level.

    Managing threads is thus a very delicate task. That's why you'd better use the built-in facilities rather than homegrowing your own with new Thread() and friends. The average Java EE application server offers a container managed thread pool which you can utilize via among others EJB's @Asynchronous and @Schedule. To be container independent (read: Tomcat-friendly), you can also use the Java 1.5's Util Concurrent ExecutorService and ScheduledExecutorService for this.

    Below examples assume Java EE 6+ with EJB.

    Fire and forget a task on form submit

    @Named
    @RequestScoped // Or @ViewScoped
    public class Bean {
    
        @EJB
        private SomeService someService;
    
        public void submit() {
            someService.asyncTask();
            // ... (this code will immediately continue without waiting)
        }
    
    }
    
    @Stateless
    public class SomeService {
    
        @Asynchronous
        public void asyncTask() {
            // ...
        }
    
    }
    

    Asynchronously fetch the model on page load

    @Named
    @RequestScoped // Or @ViewScoped
    public class Bean {
    
        private Future<List<Entity>> asyncEntities;
    
        @EJB
        private EntityService entityService;
    
        @PostConstruct
        public void init() {
            asyncEntities = entityService.asyncList();
            // ... (this code will immediately continue without waiting)
        }
    
        public List<Entity> getEntities() {
            try {
                return asyncEntities.get();
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
                throw new FacesException(e);
            } catch (ExecutionException e) {
                throw new FacesException(e);
            }
        }
    }
    
    @Stateless
    public class EntityService {
    
        @PersistenceContext
        private EntityManager entityManager;
    
        @Asynchronous
        public Future<List<Entity>> asyncList() {
            List<Entity> entities = entityManager
                .createQuery("SELECT e FROM Entity e", Entity.class)
                .getResultList();
            return new AsyncResult<>(entities);
        }
    
    }
    

    In case you're using JSF utility library OmniFaces, this could be done even faster if you annotate the managed bean with @Eager.

    Schedule background jobs on application start

    @Singleton
    public class BackgroundJobManager {
    
        @Schedule(hour="0", minute="0", second="0", persistent=false)
        public void someDailyJob() {
            // ... (runs every start of day)
        }
    
        @Schedule(hour="*/1", minute="0", second="0", persistent=false)
        public void someHourlyJob() {
            // ... (runs every hour of day)
        }
    
        @Schedule(hour="*", minute="*/15", second="0", persistent=false)
        public void someQuarterlyJob() {
            // ... (runs every 15th minute of hour)
        }
    
        @Schedule(hour="*", minute="*", second="*/30", persistent=false)
        public void someHalfminutelyJob() {
            // ... (runs every 30th second of minute)
        }
    
    }
    

    Continuously update application wide model in background

    @Named
    @RequestScoped // Or @ViewScoped
    public class Bean {
    
        @EJB
        private SomeTop100Manager someTop100Manager;
    
        public List<Some> getSomeTop100() {
            return someTop100Manager.list();
        }
    
    }
    
    @Singleton
    @ConcurrencyManagement(BEAN)
    public class SomeTop100Manager {
    
        @PersistenceContext
        private EntityManager entityManager;
    
        private List<Some> top100;
    
        @PostConstruct
        @Schedule(hour="*", minute="*/1", second="0", persistent=false)
        public void load() {
            top100 = entityManager
                .createNamedQuery("Some.top100", Some.class)
                .getResultList();
        }
    
        public List<Some> list() {
            return top100;
        }
    
    }
    

    See also: