Запуск параллельного потока для прослушивания ServerSocket

ilya.slobtsov · 11.07.2019 07:05:45

Доброго времени суток! Возможно ли запустить параллельный поток для прослушивания ServerSocket, чтобы оставались доступны экраны?

jreznot · 11.07.2019 06:52:24

Обычно рекомендуется создавать свои пулы потоков в Spring компонентах, а не в экранах. Если вам всё таки нужно сделать асинхронные вычисления в UI, то можно воспользоваться фоновыми задачами.

ilya.slobtsov · 11.07.2019 07:03:01

А в виде Scheduled Task это нельзя реализовать?

jreznot · 11.07.2019 07:39:17

Scheduled Task, по своей природе, это задача, которая должна отработать и завершиться. Вам достаточно создать поток или Executor в Spring синглтоне и обработать AppContextStoppedEvent.

Во фреймворке есть примеры таких бинов:

github.com

cuba-platform/cuba/blob/63aefb3459ec0a4b035b1d3923e405bd33b7c3c4/modules/client/src/com/haulmont/cuba/client/sys/cache/ClientCacheManager.java#L50


* Provides ability to cache any abstract object in client application
*/
@Component(ClientCacheManager.NAME)
public class ClientCacheManager {


   public static final String NAME = "cuba_ClientCacheManager";


   private static final Logger log = LoggerFactory.getLogger(ClientCacheManager.class);


   protected ConcurrentHashMap<String, CachingStrategy> cache = new ConcurrentHashMap<>();
   protected ScheduledExecutorService executorService = Executors.newScheduledThreadPool(1, new ThreadFactory() {
       final ThreadFactory defaultFactory = Executors.defaultThreadFactory();


       @Override
       public Thread newThread(@Nonnull Runnable r) {
           Thread thread = defaultFactory.newThread(r);
           thread.setName("ClientCacheManager-" + thread.getName());
           thread.setUncaughtExceptionHandler((t, e) ->
                   log.error("Unhandled exception", t)
           );
           return thread;

ilya.slobtsov · 11.07.2019 07:39:32

Спасибо за ответ!