Телеграмм чат группы jvmchat страница 18652

а есть метод по проверке залочен ключ или нет?

12:18пожаловаться #1

к сожалению нет

видел лишь намек на это вот так

if (hazelcastMap.get(key) instanceof ILock) {

}

но это даже условие не выполняется корректно, к сожалению

12:19пожаловаться #2

показываю как ложу ключ, как блокирую

        key = "testkey"; 
        hazelcastMap.put(key, "1");

        hazelcastMap.lock(key);

12:21пожаловаться #3

https://docs.hazelcast.org/docs/4.0.2/javadoc/com/hazelcast/map/IMap.html

boolean isLocked(K key)
Checks the lock for the specified key.

12:22пожаловаться #4

проверю, напишу

12:24пожаловаться #5

        if(hazelcastMap.isLocked(key)){
            System.out.println("ключ заблокирован");
        }else{
            System.out.println("ключ НЕ заблокирован");
        }

12:26пожаловаться #6

работает!

12:26пожаловаться #7

получается теперь мне нужно написать метод, если заблокирован, то вызвать следующий ключ?

мне кажется с миллионами записей будет проблема, если так сделать

12:27пожаловаться #8

keySet.stream().filter(e-> !map.isLocked(e)).findFirst()

12:28пожаловаться #9

я не работал с хазелкастом
но вижу есть метод - https://docs.hazelcast.org/docs/4.0.2/javadoc/com/hazelcast/map/IMap.html#getQueryCache-java.lang.String-com.hazelcast.query.Predicate-boolean-
мб попробовать сюда передать предикат в котором будешь проверять что ключ не заблочен и что нужен 1 элемент?

12:32пожаловаться #10

я так понял это вроде запроса sql)) понятно что даже близко не оно, но смысл понял - а что идея хорошая, изучу детальнее

12:34пожаловаться #11

спасибо!

12:35пожаловаться #12

напиши потом, к какому решению придешь

12:36пожаловаться #13

обязательно

12:36пожаловаться #14

не смог разобраться как применить для лока (

13:15пожаловаться #15

такую жесть написал, хочется получше что-то..

public class Helpers {
    public Map.Entry<Object, Object> getNextNoLockKey(HazelcastInstance hazelcastInstance, IMap hazelcastMap){
        Map.Entry<Object, Object> entry = hazelcastInstance.getMap("work-map").entrySet().iterator().next();

        if(hazelcastMap.isLocked(entry.getKey())){
            System.out.println("ключ заблокирован");
            return getNextNoLockKey(hazelcastInstance, hazelcastMap);
        }else{
            System.out.println("ключ НЕ заблокирован");
            return entry;
        }
    }
}

13:22пожаловаться #16

Vlad in pro.jvm

а то, что Михаил написал, чем не подходит?
зачем тут рекурсию делать?

keySet.stream().filter(e-> !map.isLocked(e)).findFirst()

14:03пожаловаться #17

пробую как Вы сказали

public class Helpers {
    public static String getNextNoLockKey(IMap hazelcastMap){
        return hazelcastMap.keySet().stream().filter(e-> !hazelcastMap.isLocked(e)).findFirst().toString();
    }
}

14:06пожаловаться #18

сработало, но только при условии что текущий поток заблокировал опрделенные ключи, а вот если другие потоки ключи заблокировали, тогда текщий поток даже не способен проверить на isLock

  "message": "Current thread is not owner of the lock! -> <not-locked>",

Видимо мне нужен другой подход

14:12пожаловаться #19

мне нравится подход Михаила, но реализовать технически не смог его с локами