[Java] Spring-Boot中如何使用多线程处理任务方法

/**
 * created by administrator on 2016/8/18.
 * 设置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);
 //参数封装
 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()+"运行中.....");
 }
 
}

/**
 * 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);
 
 }
 
 
}

[ info ] [2016-08-25 17:36:34] com.test.tools.spingcontexttest [57] - started spingcontexttest in 2.902 seconds (jvm running for 4.196)
2016-08-25 17:36:34.842  info 8312 --- [       main] com.test.tools.spingcontexttest      : started spingcontexttest in 2.902 seconds (jvm running for 4.196)
thread[thread-2,5,main] => com.xuele.bigdata.xalert.dao.rule.impl.greaterdaoimpl@285f38f6
thread[thread-3,5,main] => com.xuele.bigdata.xalert.dao.rule.impl.greaterdaoimpl@285f38f6
thread[thread-4,5,main] => com.xuele.bigdata.xalert.dao.rule.impl.greaterdaoimpl@285f38f6

@component
public class starttask {
 
 final static logger logger= loggerfactory.getlogger(starttask.class);
 
 //定义在构造方法完毕后，执行这个初始化方法
 @postconstruct
 public void init(){
 
  final list<monitor> list = parseruleutils.parserules();
  logger.info("监控任务的总task数：{}",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("第{}个监控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> <!-- 此处设置字符集 -->
 </encoder>
 
 <rollingpolicy class="ch.qos.logback.core.rolling.timebasedrollingpolicy">
  <!-- rollover daily 配置日志所生成的目录以及生成文件名的规则，默认是相对路径 -->
  <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> <!-- 此处设置字符集 -->
  </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>