Задача на многопоточность в Java

@Spickard · Регистрация: 07.04.2011

Студворк — интернет-сервис помощи студентам

Есть задача, которая звучит примерно следующим образом:
Есть класс SomeObjectHandler, который передаёт обработку объекта сторонней системе (см. код далее). SomeObject класс с корректно определёнными методами equals и hashCode. Метод может быть вызван многими потоками (для примера пусть будет 10). Сторонняя система хорошо работает одновременно, если SomeObject разные, но ломается, если SomeObject одинаковые. Необходимо создать свою имплeментацию метода handle так, чтобы не было одновременной обработки одинаковых SomeObject. Однако все они должны быть обработаны рано или поздно.

Java
1
2
3
4
5
6
7
8
9
public class SomeObjectHandler{
 
    private OutSystem outSystem;
 
    public void handle(SomeObject someObject ) {
        outSystem.process(someObject );
    }
 
}

Я думал над тем, чтобы использовать, например блокирующую очередь, но смущает необходимость заранее задавать размер буфера.

Помогите, пожалуйста, в поиске направления для написания решения.

@Max Dark · 28.05.2016, 23:31

Первое, что пришло в голову:

Java
1
2
3
4
5
6
7
8
9
10
public class SomeObjectHandler {
 
    private OutSystem outSystem;
 
    public void handle(SomeObject someObject ) {
        synchronized(someObject) {
            outSystem.process(someObject );
        }
    }
}

На сколько я понимаю, данный код будет лочить выполнение OutSystem :: process при одновременном вызове с одним и тем же объектом, пропуская различные копии:

Code
1
2
obj1 == obj2 -> lock
obj1 != obj2 -> run// obj1.equlas(obj2) так же пропустит

Но, честно говоря, я не уверен.

@Spickard · 28.05.2016, 23:35 **[ТС]**

Я вот подумал над одним моментом:
А при указанном вами способе разве лок будет работать при разных объектах (созданных разными new, т.е. ссылки будут разными), даже если хешкод и иквалс скажут что они равны?

@Max Dark · 28.05.2016, 23:51

Сообщение от Spickard

созданных разными new

не сработает, тк у каждого объекта будет свой собственный lock

Добавлено через 2 минуты
Сработает только если ссылки будут на один и тот же объект

@Spickard · 29.05.2016, 19:39 **[ТС]**

Жаль, а нужно чтобы они по иквалс блокировались бы в идеале.
Думаю над тем, чтобы использовать кольцевой буфер, например ArrayBlockingQueue с запоминанием последнего отправленного ключа. Если ключ уже был, класть в очередь, а её потом пытаться обходить.
Но это как-то сложно звучит + неизвестно какой размер под буфер выделять.

Добавлено через 19 часов 43 минуты
Пытаюсь сделать примерно так:

Java
1
2
3
4
5
6
7
8
9
10
11
12
private OutSystem outSystem = new OutSystem ();
 
    private ConcurrentHashMap<Key, ReentrantLock> locksMap = new ConcurrentHashMap<Key, ReentrantLock>();
 
    public void handle(Key key) {
        locksMap.putIfAbsent(key, new ReentrantLock());
        ReentrantLock lock = locksMap.get(key);
        lock.lock();
        outSystem .process(key);
        locksMap.remove(key);
        lock.unlock();
    }

Но, как мне кажется, у такого варианта проблемы с атомарностью. Можно ли как-то написать оптимальнее?

Новые блоги и статьи Все статьи Все блоги /
SDL3 для Web (WebAssembly): Загрузка PNG с прозрачным фоном с помощью SDL3_image 8Observer8 10.02.2026 Содержание блога Библиотека SDL3_image содержит инструменты для расширенной работы с изображениями. Пошагово создадим проект для загрузки изображения формата PNG с альфа-каналом (с прозрачным. . .	Установка Qt-версии Lazarus IDE в Debian Trixie Xfce volvo 10.02.2026 В общем, достали меня глюки IDE Лазаруса, собранной с использованием набора виджетов Gtk2 (конкретно: если набирать текст в редакторе и вызвать подсказку через Ctrl+Space, то после закрытия окошка. . .	SDL3 для Web (WebAssembly): Работа со звуком через SDL3_mixer 8Observer8 08.02.2026 Содержание блога Пошагово создадим проект для загрузки звукового файла и воспроизведения звука с помощью библиотеки SDL3_mixer. Звук будет воспроизводиться по клику мышки по холсту на Desktop и по. . .	SDL3 для Web (WebAssembly): Основы отладки веб-приложений на SDL3 по USB и Wi-Fi, запущенных в браузере мобильных устройств 8Observer8 07.02.2026 Содержание блога Браузер Chrome имеет средства для отладки мобильных веб-приложений по USB. В этой пошаговой инструкции ограничимся работой с консолью. Вывод в консоль - это часть процесса. . .
SDL3 для Web (WebAssembly): Обработчик клика мыши в браузере ПК и касания экрана в браузере на мобильном устройстве 8Observer8 02.02.2026 Содержание блога Для начала пошагово создадим рабочий пример для подготовки к экспериментам в браузере ПК и в браузере мобильного устройства. Потом напишем обработчик клика мыши и обработчик. . .	Философия технологии iceja 01.02.2026 На мой взгляд у человека в технических проектах остается роль генерального директора. Все остальное нейронки делают уже лучше человека. Они не могут нести предпринимательские риски, не могут. . .	SDL3 для Web (WebAssembly): Вывод текста со шрифтом TTF с помощью SDL3_ttf 8Observer8 01.02.2026 Содержание блога В этой пошаговой инструкции создадим с нуля веб-приложение, которое выводит текст в окне браузера. Запустим на Android на локальном сервере. Загрузим Release на бесплатный. . .	SDL3 для Web (WebAssembly): Сборка C/C++ проекта из консоли 8Observer8 30.01.2026 Содержание блога Если вы откроете примеры для начинающих на официальном репозитории SDL3 в папке: examples, то вы увидите, что все примеры используют следующие четыре обязательные функции, а. . .

@Spickard 7 / 7 / 0 Регистрация: 07.04.2011 Сообщений: 25
	28.05.2016, 23:35 [ТС]
	Я вот подумал над одним моментом: А при указанном вами способе разве лок будет работать при разных объектах (созданных разными new, т.е. ссылки будут разными), даже если хешкод и иквалс скажут что они равны? 0