Поток ожидающий команд (Менеджер звуков)

@FireOwl · Регистрация: 01.07.2009

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

Пишу небольшую игру на Java + Swing.
Для воспроизведения звуков у меня предназначен специальный класс-перечисление Sound.

Java

1 2	// пример - воспроизводим звук Sound.SHIELD.play();

Однако как я вскоре понял, воспроизводить звук в том же потоке, который занимается отрисовкой не стоит.
В моменты особенно "крутых замесов" были заметны легкие подлагивания. Плюс подтормаживания если в момент игры воспроизводится музыка через плеер/браузер.

Поэтому я набросал небольшой вспомогательный класс SoundManager.
Его задача - создать поток, который будет спать, и ждать команды play(Sound sound).

Java

public class SoundManager implements Runnable{
    Object lock;
    Sound toPlay;
    
    public SoundManager(){
        lock = new Object();
        new Thread(this, "Sound Thread").start();
    }
    
    public void close(){
        play(null);
    }
    
    public void play(Sound sound){
        toPlay = sound;
        synchronized(lock){ lock.notify(); }
    }
    
    public void run(){
        while(true){
            synchronized(lock){
                try {
                    lock.wait();
                    if(toPlay != null)
                        toPlay.play();
                    else break;
                } catch(InterruptedException e){ break; }
            }
        }
    }
}

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

@FireOwl · 16.05.2015, 14:09 **[ТС]**

Чтобы вопрос не висел без ответа, и не создавал ложного ощущения, что мой код идеален, запощу тут ответы, полученные мной в интернете. =)

1) Присвоение звука переменной toPlay надо тоже синхронизовать, чтобы избежать ситуации, когда два разных потока пытаются вызвать play(sound) и play(null). Из за чего переменная может проскочить проверку на null но передать классу Sound null-евое значение.

Java

public void play(Sound sound) {
    synchronized(lock){
        toPlay = sound;     
        lock.notify(); 
    }
}

Плюс, желательно ввести проверку на тот случай, если кто-то захочет воспроизвести звук на уже закрытом потоке.
Навредить это особо не сможет (как мне кажется), но было бы вежливо по отношению к юзеру метнуть ему исключение, или хотябы false.

2) Мне вообще намекнули что "не надо вам тут весь этот огород с wait-notify городить", и что надо просто сделать так:

Java

public class SoundManager {
    private final ExecutorService executor = Executors.newSingleThreadExecutor();
 
    public void playSound(Sound sound) {
        executor.execute(sound::play);
    }
 
    public void close() {
        executor.shutdown();
    }
}

Для старых версий Java функция play будет выглядеть так:

Java

public void play(final Sound sound) {
    executor.execute(new Runnable(){
        public void run(){
            sound.play();
        }
    });
}

	16.05.2015, 14:09