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);

  }

}

@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>