Spring-Boot中如何使用多線程處理任務(wù)方法

/**
 * Created by Administrator on 2016/8/18.
 * 設(shè)置Sping的上下文
 */
@Component
public class ApplicationContextProvider implements ApplicationContextAware {

 private static ApplicationContext context;

 private ApplicationContextProvider(){}

 @Override
 public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
  context = applicationContext;
 }

 public static <T> T getBean(String name,Class<T> aClass){
  return context.getBean(name,aClass);
 }
}

@Component("mTask")
@Scope("prototype")
public class MoniotrTask extends Thread {

 final static Logger logger= LoggerFactory.getLogger(MoniotrTask.class);
 //參數(shù)封裝
 private Monitor monitor;
 
 public void setMonitor(Monitor monitor) {
  this.monitor = monitor;
 }

 @Resource(name = "greaterDaoImpl")
 private RuleDao greaterDaoImpl;

 @Override
 public void run() {
  logger.info("線程:"+Thread.currentThread().getName()+"運(yùn)行中.....");
 }

}

/**
 * Created by Administrator on 2016/8/18.
 */
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes =ApplicationMain.class)
public class SpingContextTest {



 @Test
 public void show()throws Exception{
  MoniotrTask m1= ApplicationContextProvider.getBean("mTask", MoniotrTask.class);
  MoniotrTask m2=ApplicationContextProvider.getBean("mTask", MoniotrTask.class);
  MoniotrTask m3=ApplicationContextProvider.getBean("mTask", MoniotrTask.class);
  System.out.println(m1+" => "+m1.greaterDaoImpl);
  System.out.println(m2+" => "+m2.greaterDaoImpl);
  System.out.println(m3+" => "+m3.greaterDaoImpl);

 }


}

@Component
public class StartTask {

 final static Logger logger= LoggerFactory.getLogger(StartTask.class);
 
 //定義在構(gòu)造方法完畢后，執(zhí)行這個(gè)初始化方法
 @PostConstruct
 public void init(){

  final List<Monitor> list = ParseRuleUtils.parseRules();
  logger.info("監(jiān)控任務(wù)的總Task數(shù)：{}",list.size());
  for(int i=0;i<list.size();i++) {
   MoniotrTask moniotrTask= ApplicationContextProvider.getBean("mTask", MoniotrTask.class);
   moniotrTask.setMonitor(list.get(i));
   moniotrTask.start();
   logger.info("第{}個(gè)監(jiān)控task: {}啟動 !",(i+1),list.get(i).getName());
  }
 }
}

<!-- Logback configuration. See http://logback.qos.ch/manual/index.html -->
<configuration scan="true" scanPeriod="10 seconds">
 <!-- Simple file output -->
 <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">
 <!--<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">-->
 <!-- encoder defaults to ch.qos.logback.classic.encoder.PatternLayoutEncoder -->
 <encoder>
  <pattern>
   [ %-5level] [%date{yyyy-MM-dd HH:mm:ss}] %logger{96} [%line] - %msg%n
  </pattern>
  <charset>UTF-8</charset> <!-- 此處設(shè)置字符集 -->
 </encoder>

 <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
  <!-- rollover daily 配置日志所生成的目錄以及生成文件名的規(guī)則，默認(rèn)是相對路徑 -->
  <fileNamePattern>logs/xalert-%d{yyyy-MM-dd}.%i.log</fileNamePattern>
  <!--<property name="logDir" value="E:/testlog" />-->
  <!--絕對路徑定義-->
  <!--<fileNamePattern>${logDir}/logs/xalert-%d{yyyy-MM-dd}.%i.log</fileNamePattern>-->
  <timeBasedFileNamingAndTriggeringPolicy
   class="ch.qos.logback.core.rolling.SizeAndTimeBasedFNATP">
  <!-- or whenever the file size reaches 64 MB -->
  <maxFileSize>64 MB</maxFileSize>
  </timeBasedFileNamingAndTriggeringPolicy>
 </rollingPolicy>


 <filter class="ch.qos.logback.classic.filter.ThresholdFilter">
  <level>DEBUG</level>
 </filter>
 <!-- Safely log to the same file from multiple JVMs. Degrades performance! -->
 <prudent>true</prudent>
 </appender>


 <!-- Console output -->
 <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
 <!-- encoder defaults to ch.qos.logback.classic.encoder.PatternLayoutEncoder -->
  <encoder>
   <pattern>
    [ %-5level] [%date{yyyy-MM-dd HH:mm:ss}] %logger{96} [%line] - %msg%n
   </pattern>
   <charset>UTF-8</charset> <!-- 此處設(shè)置字符集 -->
  </encoder>
 <!-- Only log level WARN and above -->
 <filter class="ch.qos.logback.classic.filter.ThresholdFilter">
  <level>INFO</level>
 </filter>
 </appender>


 <!-- Enable FILE and STDOUT appenders for all log messages.
  By default, only log at level INFO and above. -->
 <root level="INFO">
  <appender-ref ref="STDOUT" />
  <appender-ref ref="FILE" />

 </root>

 <!-- For loggers in the these namespaces, log at all levels. -->
 <logger name="pedestal" level="ALL" />
 <logger name="hammock-cafe" level="ALL" />
 <logger name="user" level="ALL" />
 <include resource="org/springframework/boot/logging/logback/base.xml"/>
 <jmxConfigurator/>
</configuration>