如何防止客戶端崩潰時事務死鎖？

Question

代碼在我的服務器：

  TransactionContext txCxt = hz.newTransactionContext(txop); 
      txCxt.beginTransaction(); 
      TransactionalMap<Object, Object> map = txCxt.getMap(NearCacheTest.MAP); 

      try { 
       String tmp = String.valueOf(System.currentTimeMillis()); 
       map.put("1", tmp); // reader1 is blocked 
       tmp = String.valueOf(System.currentTimeMillis()); 
       map.put("2", tmp); // reader2 is blocked 

       // evict all client map cache 
       IList<Object> evictList = hz.getList(NearCacheTest.SEMAPHORE_EVICT); 
       evictList.add("1"); 
       evictList.add("2"); 

       int size = hz.getClientService().getConnectedClients().size(); 
       hz.getSemaphore(NearCacheTest.SEMAPHORE_EVICT).release(size); 
       hz.getAtomicLong(NearCacheTest.SEMAPHORE_EVICT).set(size); 
       logger.info("client count:{}", size); 

       // wait to response from clients 
       logger.info("waiting for event:{}", NearCacheTest.SEMAPHORE_ACK); 
       hz.getSemaphore(NearCacheTest.SEMAPHORE_ACK).acquire(); 

我的問題是： 當一個客戶端崩潰了，semaphore_ack永遠不能被釋放;

我該怎麼做才能防止死鎖？

Answer 1

    // evict all client map cache 
       IList<Object> evictList = hz.getList(NearCacheTest.SEMAPHORE_EVICT); 
       evictList.add("1"); 
       evictList.add("2"); 

       int size = hz.getClientService().getConnectedClients().size(); 
       ISemaphore semaphore = hz.getSemaphore(NearCacheTest.SEMAPHORE_EVICT); 
       semaphore.release(size); 
       logger.info("client count:{}", size); 

       // wait to response from clients 
       while (semaphore.tryAcquire()) { 
       }