apiroute/apiroute-service/src/main/java/org/onap/msb/apiroute/wrapper/queue/BaseQueue.java

   1 package org.onap.msb.apiroute.wrapper.queue;
   2
   3 import java.util.ArrayList;
   4 import java.util.List;
   5 import java.util.concurrent.BlockingQueue;
   6 import java.util.concurrent.LinkedBlockingQueue;
   7
   8 public abstract class BaseQueue<T> {
   9
  10   private final List<BlockingQueue<ServiceData<T>>> queueArray= new ArrayList<BlockingQueue<ServiceData<T>>>();
  11
  12   public BaseQueue(int queueNum,int queueCapacity)
  13   {
  14       for(int i=0;queueNum>0 && i<queueNum;i++)
  15       {
  16           queueArray.add(new LinkedBlockingQueue<ServiceData<T>>(queueCapacity));
  17       }
  18   }
  19
  20   public int getQueneNum(){
  21     return queueArray.size();
  22   }
  23
  24   protected BlockingQueue<ServiceData<T>> getQueue(int index)
  25   {
  26       return queueArray.get(index);
  27   }
  28
  29   public abstract void put(final ServiceData<T> data) throws InterruptedException;
  30
  31   public abstract ServiceData<T> take(final int queueIndex) throws InterruptedException;
  32
  33
  34
  35
  36 }