ParkWaitStrategy.java

  private AtomicReferenceArray<Thread> consumerWorker;

	
	@Override
	public void block() throws InterruptedException {		
		boolean parked=false;
		for(int index=0;index<consumer;index++)
		{
			
			if(consumerWorker.get(index)==null && consumerWorker.compareAndSet(index, null, Thread.currentThread()))
			{
				parked=true;
				LockSupport.park(this);	
				break;
			}
		}		
		if(!parked)
		{
			//Unable to park because no slots available then park for some time
			LockSupport.parkNanos(this, TimeUnit.MILLISECONDS.toNanos(10));			
		}		
	}

	@Override
	public void release() {
		for(int index=0;index<consumer;index++)
		{
			Thread threadToNotify = consumerWorker.get(index);
			if(threadToNotify!=null)
			{
				consumerWorker.set(index, null);				
				LockSupport.unpark(threadToNotify);
			}
			
		}
	}