springmvc配置线程池Executor做多线程并发操作的代码实例

xmlns:task= "http://HdhCmsTestspringframework.org/schema/task"

http: //HdhCmsTestspringframework.org/schema/task

http: //HdhCmsTestspringframework.org/schema/task/spring-task.xsd

<bean id= "taskexecutor" class = "org.springframework.scheduling.concurrent.threadpooltaskexecutor" >

     <!-- 核心线程数 -->   

     <property name= "corepoolsize" value= "${task.core_pool_size}" />

     <!-- 最大线程数 --> 

     <property name= "maxpoolsize" value= "${task.max_pool_size}" />

     <!-- 队列最大长度 -->

     <property name= "queuecapacity" value= "${task.queue_capacity}" />

     <!-- 线程池维护线程所允许的空闲时间，默认为60s -->

     <property name= "keepaliveseconds" value= "${task.keep_alive_seconds}" />

   </bean>

   <!-- 注解式 -->

   <task:annotation-driven />

maxopenpreparedstatements= 20

removeabandoned= true

removeabandonedtimeout= 1800

logabandoned= true

@resource (name = "taskexecutor" )

private taskexecutor taskexecutor;

taskexecutor.execute( new runnable() {

   @override

   public void run() {

     // todo auto-generated method stub

     try {

        //要进行的并发操作

     } catch (exception e) {

       // todo auto-generated catch block

       e.printstacktrace();

     }

   }

});

@controller

public class indexcontroller {

int studentscount = 0 ;

@requestmapping (value = "/index.html" )

   public modelandview goindex() {

     logbefore(logger, "列表center" );

     modelandview mv = this .getmodelandview();

         taskexecutor.execute( new runnable() {

         @override

         public void run() {

           // todo auto-generated method stub

           // 得到所有学生人数

           try {

                      studentscount = coursesservice.getstudentcount(pd);

           } catch (exception e) {

             // todo auto-generated catch block

             e.printstacktrace();

           }

         }

       });

          mv.addobject( "studentscount" , studentscount);

          mv.setviewname( "common/index" );

          return mv;

｝