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

такую жесть написал, хочется получше что-то.. 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; } } }

0

04.05.2021

Владислав Хакин

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

а то, что Михаил написал, чем не подходит? зачем тут рекурсию делать? keySet.stream().filter(e-> !map.isLocked(e)).findFirst()

0

04.05.2021

As@@t A Автор вопроса

Владислав Хакин
а то, что Михаил написал, чем не подходит? зачем т...

пробую как Вы сказали public class Helpers { public static String getNextNoLockKey(IMap hazelcastMap){ return hazelcastMap.keySet().stream().filter(e-> !hazelcastMap.isLocked(e)).findFirst().toString(); } }

0

04.05.2021

As@@t A Автор вопроса

As@@t A
пробую как Вы сказали public class Helpers { ...

сработало, но только при условии что текущий поток заблокировал опрделенные ключи, а вот если другие потоки ключи заблокировали, тогда текщий поток даже не способен проверить на isLock "message": "Current thread is not owner of the lock! -> <not-locked>", Видимо мне нужен другой подход

0

04.05.2021

As@@t A Автор вопроса

Владислав Хакин
а то, что Михаил написал, чем не подходит? зачем т...

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

0

04.05.2021

Владислав Хакин

As@@t A
сработало, но только при условии что текущий поток...

это exception? это получается, что ключ заблокирован, но другим потоком. Можно считать - заблокированным вцелом, при filter. просто сделать try-catch в filter может это xy проблем и не нужно определять незаблокированный ключ вообще?

0

04.05.2021

As@@t A Автор вопроса

Владислав Хакин
это exception? это получается, что ключ заблокиров...

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

0

04.05.2021

Владислав Хакин

As@@t A
Хотя вопрос а как потом получить разблокированный ...

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

0

04.05.2021

As@@t A Автор вопроса

Владислав Хакин
ну следующий в списке нужно проверить, пока не най...

Тогда уж циклом each бахнуть и проверять до первого свободного .. но вдруг миллион ключей - что тогда?

0

04.05.2021

Владислав Хакин

As@@t A
Тогда уж циклом each бахнуть и проверять до первог...

так стрим тоже самое сделает. А если миллион ключей, то xy проблем и вопрос для чего это вообще?)

0

04.05.2021

Михаил · Accepted Answer

Михаил

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

0

04.05.2021

170 похожих чатов

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

16 ответов

Похожие вопросы