public void await(long timeout, TimeUnit unit)
            throws InterruptedException, TimeoutException {
        if (!latch.await(timeout, unit)) {
            throw new TimeoutException(errMsgInfo);
        }
    }
Waits for the CallFuture to complete without returning the result.

@param timeout the maximum time to wait.
@param unit    the time unit of the timeout argument.
@throws InterruptedException                  if interrupted.
@throws java.util.concurrent.TimeoutException if the wait timed out.
inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corerpc/client/CallFuture.java