интересный кусок кода
public void run() {
while (!stopped) {
Object msg = queue.pull();
if (!stopped) {
processor.processMessage(msg);
}
}
}
while (!stopped) {
Object msg = queue.pull();
if (!stopped) {
processor.processMessage(msg);
}
}
}
Вот такой интересный кусочек кода нашёлся при просмотре кода Unimd’a, т.е. queue.pull() не изменяет stopped, я так полагаю эта проверка возникла из за того, что это чудо моногопоточное, но даже в этом случае от этой проверки на мой взгляд толку не очень много. А нам в этой хернёй приходится работать, и собственно вылазят ошибки, походу будем переписывать это чудо, хз только будет толк ли нет.
upd:толка от наших изменений никакого(