incrementAndGet(); try { // check if we have an in-progress batch Deque<RecordBatch> dq = getOrCreateDeque(tp); synchronized (dq) { if ...
確定! 回上一頁