Состояние гонки в синхронизированном массиве
Я включаю обработку списка объектов в синхронизированный блок, но оказался в состоянии гонки. Я использую синхронизированный блок неправильно или есть другие проблемы с моим кодом? Список фактически создается с помощью mapdb.
private static List<MessageHolder> msgHolders;
//messageSequenceDB instantiation
msgHolders = (List<MessageHolder>) messageSequenceDB.indexTreeList("tempStorage", Serializer.JAVA).createOrOpen();
synchronized (msgHolders) {
System.out.println(Thread.currentThread().getName() +"->"+msgHolders.toString());
for (MessageHolder holder : msgHolders) {
if(holder.getStatus().equalsIgnoreCase(STATUS_INITIAL) {
holder.setStatus(STATUS_DISPATCHED);
LOGGER.info("MESSAGE SEQUENCER: Message {} dispatched", holder);
//Remaining code
}}}
Я ожидаю, что один объект будет обработан только одним потоком. Если второй поток попытается отправить его, условие о состоянии не будет выполнено. Но я получаю вывод, как только несколько сообщений обрабатываются всеми потоками.
Предоставление образца вывода здесь.
pool-12-thread-1->[MessageHolder [key=TradeId.1, message=1, status=Initial], MessageHolder [key=TradeId.2, message=222, status=Initial]]
pool-12-thread-2->[MessageHolder [key=TradeId.2, message=222, status=Initial], MessageHolder [key=TradeId.1, message=1111, status=Initial]]
pool-12-thread-3->[MessageHolder [key=TradeId.2, message=222, status=Initial]]
pool-12-thread-1->[MessageHolder [key=TradeId.1, message=11, status=Initial]]
Сообщение с идентификатором 222 обрабатывается всеми 3 потоками. что я должен сделать для обеспечения синхронизации?