app-c/appc/appc-dispatcher/appc-dispatcher-common/execution-queue-management-lib/src/main/java/org/openecomp/appc/executionqueue/helper/Util.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * openECOMP : APP-C
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights
   6  *                                              reserved.
   7  * ================================================================================
   8  * Licensed under the Apache License, Version 2.0 (the "License");
   9  * you may not use this file except in compliance with the License.
  10  * You may obtain a copy of the License at
  11  *
  12  *      http://www.apache.org/licenses/LICENSE-2.0
  13  *
  14  * Unless required by applicable law or agreed to in writing, software
  15  * distributed under the License is distributed on an "AS IS" BASIS,
  16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  17  * See the License for the specific language governing permissions and
  18  * limitations under the License.
  19  * ============LICENSE_END=========================================================
  20  */
  21
  22 package org.openecomp.appc.executionqueue.helper;
  23
  24 import java.util.concurrent.Executors;
  25 import java.util.concurrent.ThreadFactory;
  26
  27 import org.openecomp.appc.configuration.Configuration;
  28 import org.openecomp.appc.configuration.ConfigurationFactory;
  29
  30 public class Util {
  31
  32     private static final Configuration configuration = ConfigurationFactory.getConfiguration();
  33
  34     public static int DEFAULT_QUEUE_SIZE = 10;
  35     public static int DEFAULT_THREADPOOL_SIZE = 10;
  36
  37     public static int getExecutionQueSize(){
  38         String sizeStr = configuration.getProperty("appc.dispatcher.executionqueue.backlog.size", String.valueOf(DEFAULT_QUEUE_SIZE));
  39         int size = DEFAULT_QUEUE_SIZE;
  40         try{
  41             size = Integer.parseInt(sizeStr);
  42         }
  43         catch (NumberFormatException e){
  44
  45         }
  46         return size;
  47     }
  48
  49     public static int getThreadPoolSize(){
  50         String sizeStr = configuration.getProperty("appc.dispatcher.executionqueue.threadpool.size", String.valueOf(DEFAULT_THREADPOOL_SIZE));
  51         int size = DEFAULT_THREADPOOL_SIZE;
  52         try{
  53             size = Integer.parseInt(sizeStr);
  54         }
  55         catch (NumberFormatException e){
  56
  57         }
  58         return size;
  59     }
  60
  61     public static ThreadFactory getThreadFactory(final boolean isDaemon){
  62         return new ThreadFactory() {
  63             final ThreadFactory factory = Executors.defaultThreadFactory();
  64             public Thread newThread(Runnable r) {
  65                 Thread t = factory.newThread(r);
  66                 t.setDaemon(isDaemon);
  67                 return t;
  68             }
  69         };
  70     }
  71 }