Java 类org.apache.hadoop.hbase.ipc.CallRunner 实例源码

@Override
public boolean dispatch(CallRunner task) throws IOException, InterruptedException {
  int priority = task.getCall().getPriority();

  if (priority > HConstants.QOS_THRESHOLD) {
    numPriorityCalls++;
  }
  return super.dispatch(task);
}

@Override
public void dispatch(final CallRunner task) throws IOException, InterruptedException {
  executor.submit(new Runnable() {
    @Override
    public void run() {
      task.run();
    }
  });
}

@Override
public void dispatch(final CallRunner task) throws IOException, InterruptedException {
  executor.submit(new Runnable() {
    @Override
    public void run() {
      task.run();
    }
  });
}

@Override
public boolean dispatch(CallRunner task) throws IOException, InterruptedException {
  int priority = task.getRpcCall().getPriority();

  if (priority > HConstants.QOS_THRESHOLD) {
    numPriorityCalls++;
  }
  return super.dispatch(task);
}

@Override
public void dispatch(final CallRunner task) throws IOException, InterruptedException {
  executor.submit(new Runnable() {
    @Override
    public void run() {
      task.run();
    }
  });
}