[Java] Spring Cloud Hystrix 线程池队列配置(踩坑)

hystrix:
 threadpool:
  default:
   coresize: 200 #并发执行的最大线程数，默认10
   maxqueuesize: 1000 #blockingqueue的最大队列数，默认值-1
   queuesizerejectionthreshold: 800 #即使maxqueuesize没有达到，达到queuesizerejectionthreshold该值后，请求也会被拒绝，默认值5

/**
 * @author: xiongfeng
 * @description:
 * @date: created in 11:12 2018/6/11
 */
public class repaymenthelpertest extends fundapplicationtests {
 
  @autowired
  repaymenthelper repaymenthelper;
  @autowired
  private routerfeign routerfeign;
 
  @test
  public void hystrixtest() throws interruptedexception {
 
  for (int i = 0; i < 135; i++) {
    new thread(new runnable() {
    @override
    public void run() {
      job();
    }
    }).start();
  }
 
  thread.currentthread().join();
  }
 
  public void job() {
  string repaymentno = "xf1002";
  string transno = "t4324324234";
  string reqno = "xf1002";
  string begintime = "20180831130030";
  string endtime = "20180831130050";
 
  transrecqueryreqdto transrecqueryreqdto = new transrecqueryreqdto();
  transrecqueryreqdto.settransno(transno);
  transrecqueryreqdto.setbegintime(begintime);
  transrecqueryreqdto.setendtime(endtime);
  transrecqueryreqdto.setreqno(reqno);
 
  resp<list<transrecdto>> querytransreclistresp = routerfeign.querytransrec(new req<>(repaymentno, "2018080200000002", null, null, transrecqueryreqdto));
 
  system.out.println(string.format("获取结果为：【%s】", jsonutil.tojson(querytransreclistresp)));
  }
}

@feignclient(value = "${core.name}", fallbackfactory = routerfeignbackfactory.class, path = "/router")
public interface routerfeign {
 
  /**
   * 代扣结果查询
   * @param transrecqueryreqdtoreq
   * @return
   */
  @postmapping("/querytransrec")
  resp<list<transrecdto>> querytransrec(@requestbody req<transrecqueryreqdto> transrecqueryreqdtoreq);
 
}

/**
 * @author: xiongfeng
 * @description:
 * @date: created in 16:04 2018/5/24
 */
@api("还款服务")
@refreshscope
@restcontroller
@requestmapping("/router")
public class testcontroller {
 
  private static logger logger = loggerfactory.getlogger(testcontroller.class);
 
  // 计数器
  private static atomicinteger count = new atomicinteger(1);
 
  @apioperation(value = "代扣结果查询")
  @postmapping("/querytransrec")
  resp<list<transrecdto>> querytransrec(@requestbody req<transrecqueryreqdto> transrecqueryreqdtoreq) throws interruptedexception {
  system.out.println(string.format("查询支付结果......计数： %s", count.getandadd(1)));
  thread.sleep(500);
  return resp.success(respstatus.success.getdesc(), null);
  }

hystrix:
 threadpool:
  default:
   coresize: 10
   maxqueuesize: 1000
   queuesizerejectionthreshold: 20

hystrix:
 threadpool:
  default:
   coresize: 10
   maxqueuesize: 15
   queuesizerejectionthreshold: 2000

java.util.concurrent.rejectedexecutionexception: task java.util.concurrent.futuretask@7d6d472b rejected from java.util.concurrent.threadpoolexecutor@17f8bcb7[running, pool size = 3, active threads = 3, queued tasks = 15, completed tasks = 0]

hystrix:
 threadpool:
  default:
   coresize: 10
   maxqueuesize: 1500

java.util.concurrent.rejectedexecutionexception: rejected command because thread-pool queuesize is at rejection threshold.

hystrix:
 threadpool:
  default:
   coresize: 10
   queuesizerejectionthreshold: 1000

java.util.concurrent.rejectedexecutionexception: task java.util.concurrent.futuretask@23d268ea rejected from java.util.concurrent.threadpoolexecutor@66d0e2f4[running, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0]
at java.util.concurrent.threadpoolexecutor$abortpolicy.rejectedexecution(threadpoolexecutor.java:2063)
at java.util.concurrent.threadpoolexecutor.reject(threadpoolexecutor.java:830)
at java.util.concurrent.threadpoolexecutor.execute(threadpoolexecutor.java:1379)
at java.util.concurrent.abstractexecutorservice.submit(abstractexecutorservice.java:112)

hystrix:
 threadpool:
  default:
   coresize: 10
   maxqueuesize: 1500
   queuesizerejectionthreshold: 1000