utils/DmaapPublisher/src/main/java/org/openecomp/sdc/dmaap/RequestManager.java

   1 package org.openecomp.sdc.dmaap;
   2
   3 import java.util.concurrent.Executor;
   4 import java.util.concurrent.Executors;
   5
   6 public class RequestManager {
   7
   8     private Executor executor;
   9
  10     public RequestManager(int poolSize ){
  11         int sz = Math.max( poolSize , 1);
  12         int recommendedMaxSz = Runtime.getRuntime().availableProcessors() * 2;
  13         executor = Executors.newFixedThreadPool( Math.min( sz , recommendedMaxSz ) );
  14     }
  15
  16     public Executor getExecutor() {
  17         return executor;
  18     }
  19 }