code: @SuppressWarnings("unchecked")
      public boolean execute(Runnable r) {
      	
      	try {
  			queue[queue_no++ % nThreads].putFirst(r);
  			if (queue_no == nThreads){
  				queue_no = 0;
  			}
              return true;
  		} catch (InterruptedException e) {
              String info = "Failed to enqueue task: ";
              Throwable baseCause = org.gautelis.vopn.lang.Stacktrace.getBaseCause(e);
              info += baseCause.getMessage();
              log.warn(info, e);
  		}
          return false;
      }
docs: /*
  Executes the given task in the future.
  Queues the task and notifies the waiting thread. Also it makes
  the Work assigner to wait if the queued task reaches to threshold