如何在客户端崩溃时防止事务死锁

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()) {
                }