Refactor audio manager, add line pool.

Mage.Client/src/main/java/mage/client/util/audio/LinePool.java

@@ -0,0 +1,118 @@
+package mage.client.util.audio;
+
+import java.util.HashSet;
+import java.util.LinkedList;
+import java.util.Set;
+import java.util.Timer;
+import java.util.TimerTask;
+
+import javax.sound.sampled.AudioFormat;
+import javax.sound.sampled.AudioSystem;
+import javax.sound.sampled.DataLine;
+import javax.sound.sampled.LineUnavailableException;
+import javax.sound.sampled.Mixer;
+import javax.sound.sampled.Mixer.Info;
+import javax.sound.sampled.SourceDataLine;
+
+import mage.utils.ThreadUtils;
+
+public class LinePool {
+
+    private static final int LINE_CLEANUP_INTERVAL = 30000;
+    AudioFormat format;
+    Set<SourceDataLine> freeLines = new HashSet<>();
+    Set<SourceDataLine> activeLines = new HashSet<>();
+    Set<SourceDataLine> busyLines = new HashSet<>();
+    LinkedList<MageClip> queue = new LinkedList<>();
+
+    /*
+     * Initially all the lines are in the freeLines pool. When a sound plays, one line is being selected randomly from
+     * the activeLines and then, if it's empty, from freeLines pool and used to play the sound. The line is moved to
+     * busyLines. When a sound stops, the line is moved to activeLines if it contains <= elements than alwaysActive
+     * parameter, else it's moved to the freeLines pool.
+     */
+
+    private Mixer mixer;
+    private int alwaysActive;
+
+    public LinePool() {
+        this(new AudioFormat(22050, 16, 1, true, false), 4, 1);
+    }
+
+    public LinePool(AudioFormat audioFormat, int size, int alwaysActive) {
+        format = audioFormat;
+        this.alwaysActive = alwaysActive;
+        Info[] mixerInfos = AudioSystem.getMixerInfo();
+        Mixer.Info mInfo = null;
+        if (mixerInfos.length > 0) {
+            mInfo = mixerInfos[0];
+        }
+        mixer = AudioSystem.getMixer(mInfo);
+        DataLine.Info lineInfo = new DataLine.Info(SourceDataLine.class, audioFormat);
+        for (int i = 0; i < size; i++) {
+            try {
+                final SourceDataLine line = (SourceDataLine) mixer.getLine(lineInfo);
+                freeLines.add(line);
+            } catch (LineUnavailableException e) {
+                e.printStackTrace();
+            }
+        }
+        new Timer("Line cleanup", true).scheduleAtFixedRate(new TimerTask() {
+
+            @Override
+            public void run() {
+                synchronized (LinePool.this) {
+                    for (SourceDataLine sourceDataLine : freeLines) {
+                        sourceDataLine.close();
+                    }
+                }
+            }
+        }, LINE_CLEANUP_INTERVAL, LINE_CLEANUP_INTERVAL);
+    }
+
+    public void playSound(final MageClip mageClip) {
+        final SourceDataLine line;
+        synchronized (LinePool.this) {
+            if (activeLines.size() > 0) {
+                line = activeLines.iterator().next();
+            } else if (freeLines.size() > 0) {
+                line = freeLines.iterator().next();
+            } else {
+                // no lines available, queue sound to play it when a line is available
+                queue.add(mageClip);
+                return;
+            }
+            freeLines.remove(line);
+            activeLines.remove(line);
+            busyLines.add(line);
+        }
+        ThreadUtils.threadPool.submit(new Runnable() {
+
+            @Override
+            public void run() {
+                try {
+                    if (!line.isOpen()) {
+                        line.open();
+                    }
+                    line.start();
+                } catch (LineUnavailableException e) {
+                    e.printStackTrace();
+                }
+                byte[] buffer = mageClip.getBuffer();
+                line.write(buffer, 0, buffer.length);
+                synchronized (LinePool.this) {
+                    boolean hasQueue = queue.size() > 0;
+                    busyLines.remove(line);
+                    if (activeLines.size() < LinePool.this.alwaysActive) {
+                        activeLines.add(line);
+                    } else {
+                        freeLines.add(line);
+                    }
+                    if (hasQueue) {
+                        playSound(queue.poll());
+                    }
+                }
+            }
+        });
+    }
+}