TCPDefaultConnection.java 文件源码

@Override
protected synchronized void beforeSend(final Object object) {
    NetCom2Utils.assertNotNull(object);
    if (object.getClass().equals(Acknowledge.class)) {
        logging.trace("[TCP] No need to setup an synchronization mechanism an Acknowledge!");
        return;
    }
    logging.trace("[TCP] Locking access to send ..");
    communicationLock.lock();
    logging.debug("[TCP] Preparing send of " + object + " at Thread " + Thread.currentThread());
    final Semaphore semaphore = new Semaphore(1);
    logging.trace("[TCP] ClientMapping synchronization mechanism ..");
    synchronized (mapping) {
        mapping.put(object.getClass(), semaphore);
    }
    logging.trace("[TCP] Setting up Callback ..");
    receivingService.addReceivingCallback(new TCPAckCallback(object.getClass()));
}