1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 package org.apache.syncope.core.starter;
20
21 import java.util.HashMap;
22 import java.util.Map;
23 import org.apache.syncope.core.persistence.api.SyncopeCoreLoader;
24 import org.slf4j.Logger;
25 import org.slf4j.LoggerFactory;
26 import org.springframework.beans.factory.ListableBeanFactory;
27 import org.springframework.scheduling.concurrent.ExecutorConfigurationSupport;
28
29 public class TaskExecutorUnloader implements SyncopeCoreLoader {
30
31 protected static final Logger LOG = LoggerFactory.getLogger(TaskExecutorUnloader.class);
32
33 protected final ListableBeanFactory beanFactory;
34
35 protected final Map<String, ExecutorConfigurationSupport> tptes = new HashMap<>();
36
37 public TaskExecutorUnloader(final ListableBeanFactory beanFactory) {
38 this.beanFactory = beanFactory;
39 }
40
41 @Override
42 public int getOrder() {
43 return Integer.MIN_VALUE;
44 }
45
46 @Override
47 public void load() {
48 tptes.putAll(beanFactory.getBeansOfType(ExecutorConfigurationSupport.class));
49 }
50
51 @Override
52 public void unload() {
53 tptes.forEach((name, tpte) -> {
54 LOG.info("Shutting down ThreadPoolTaskExecutor {}...", name);
55 try {
56 tpte.shutdown();
57
58 LOG.info("Successfully shut down ThreadPoolTaskExecutor {}", name);
59 } catch (Exception e) {
60 LOG.error("While shutting down ThreadPoolTaskExecutor {}", name, e);
61 }
62 });
63 }
64 }