c/c++语言开发共享@Transaction,@Async在同一个类中注解失效的原因分析及解决

目录

• @transaction @async在同一个类中注解失效
• 下面用伪代码阐述一下原因
• 说说解决
• @async的实现类方式
• 方法1：实现接口asyncconfigurer
• 方法2：直接注入bean

  @service  public class testasyncservice {    public void testasync() throws exception {      test();    }    @async    public void test() throws interruptedexception{      thread.sleep(10000);//让线程休眠，根据输出结果判断主线程和从线程是同步还是异步      system.out.println("异步threadid:"+thread.currentthread().getid());    }  }  

  @service    class a{        @async      method b(){...}        method a(){    //标记1            b();        }    }    //spring扫描注解后，创建了另外一个代理类，并为有注解的方法加上异步效果    class proxy$a{        a objecta = new a();        method b(){    //标记2            //异步执行async            objecta.b();        }        method a(){    //标记3            objecta.a();    //由于a()没有注解，所以不会异步执行，而是直接调用a的实例的a()方法        }    }    

  @configuration  public class threadconfiguration implements asyncconfigurer {      private logger logger = loggerfactory.getlogger(this.getclass());      private final threadpooltaskexecutor executor = new threadpooltaskexecutor();      @bean      public executor getasyncexecutor() {          executor.setthreadnameprefix("zy-taskexecutor-");          executor.setcorepoolsize(50);// 核心线程池大小          executor.setmaxpoolsize(200);// 最大可创建的线程数          executor.setqueuecapacity(1000);// 队列最大长度          executor.setkeepaliveseconds(300);// 线程池维护线程所允许的空闲时间          executor.setrejectedexecutionhandler(new threadpoolexecutor.callerrunspolicy());          executor.initialize();          logger.info("任务线程池初始化...");          return executor;      }      /**       * 只有在方法上添加@async的出现异常才会跳到此方法中       * */      @override      public asyncuncaughtexceptionhandler getasyncuncaughtexceptionhandler() {          logger.error("线程执行出现异常....");          return (e, method, arguments) -> logger.error("exception method : " + method.getname() + " message:" + e.getmessage(), e);      }      /**       * 线程监控类,访问/monitor       * */      @bean      public servletregistrationbean threadpoolmonitorservlet() {          servletregistrationbean registration = new servletregistrationbean(new httpservlet() {              @override              protected void service(httpservletrequest req, httpservletresponse resp) throws servletexception, ioexception {                  resp.setcontenttype(mediatype.application_json_utf8_value);                  printwriter writer = resp.getwriter();                  writer.print("corepoolsize : " + executor.getcorepoolsize());                  writer.flush();                  writer.close();              }          });          registration.addurlmappings("/monitor/*");          logger.info("springboot线程监控start!");          return registration;      }  }  

  @bean      public threadpooltaskexecutor threadpooltaskexecutor(){          threadpooltaskexecutor executor = new threadpooltaskexecutor();          executor.setmaxpoolsize(200);          executor.setqueuecapacity(1000);          executor.setcorepoolsize(50);          executor.setkeepaliveseconds(300);          executor.setthreadnameprefix("zy-taskexecutor-");          // 线程池对拒绝任务(无线程可用)的处理策略          executor.setrejectedexecutionhandler(new threadpoolexecutor.callerrunspolicy());          executor.initialize();          log.info("任务线程池初始化...");          return executor;      }