JLayer同步

（我试图使我之前的问题更加通用，希望能找到解决方案。）我正在使用JLayer库和sample.mp3文件。我想同时播放和解码文件。但是，我想让它们同步 - 如果歌曲的一部分被解码，它也会被播放。在播放之前没有任何内容被解码，反之亦然（当然，在合理的程度上）。以下是尊重地播放和解码歌曲的方式：

Player p = new Player(InputStream mp3stream);
p.play();

Decoder d = new Decoder();
BitStream bs = new Bitstream(InputStream mp3stream);
SampleBuffer s = (SampleBuffer) d.decodeFrame(bs.readFrame(), bs);
// ... for processing the SampleBuffer but irrelevant for the question

我目前使用：

InputStream mp3stream = new FileInputStream("sample.mp3");

但这一次使用了整首歌，所以我无法同步。有没有办法将sample.mp3分解为可由两个进程操作的片段？如果我有足够小的碎片，我可以将两个碎片都放进过程中，等到两个碎片完成，然后抓住下一个小碎片重复，直到我的碎片变小。注意：我尝试使用ByteArrayInputStream但没有成功 - 但使用它时我的方法可能不正确。

已邀请:

1 个回复

糕泰灌

我希望我做对了：您有一个输入文件您希望在这个意义上同步两个不同的输入流，即“它们必须在流中进行相同的进展”。这是一个有问题的问题。我想出了下面的草图（编译，但没有执行它，所以你可以先做一点测试）。创建一个包装器对象“StreamSynchronizer”，用于控制对底层输入的访问。在所有派生流都读取此字节之前，只读取一个字节。从中派生任意数量的“SynchronizedStream”实例，将“读取”委托给StreamSynchronizer。

package de.mit.stackoverflow;

import java.io.IOException;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.HashSet;
import java.util.List;
import java.util.Set;

public class StreamSynchronizer {

    final private InputStream inputStream;

    private List activeStreams = new ArrayList();

    private int lastByte;

    private Set waitingStreams = new HashSet();

    private Object lock = new Object();

    public StreamSynchronizer(InputStream is) throws IOException {
        super();
        this.inputStream = is;
        lastByte = getInputStream().read();
    }

    public void close(SynchronizedStream stream) {
        activeStreams.remove(stream);
    }

    public SynchronizedStream createStream() {
        SynchronizedStream stream = new SynchronizedStream(this);
        activeStreams.add(stream);
        return stream;
    }

    public InputStream getInputStream() {
        return inputStream;
    }

    public int read(SynchronizedStream stream) throws IOException {
        synchronized (lock) {
            while (waitingStreams.contains(stream)) {
                if (waitingStreams.size() == activeStreams.size()) {
                    waitingStreams.clear();
                    lastByte = getInputStream().read();
                    lock.notifyAll();
                } else {
                    try {
                        lock.wait();
                    } catch (InterruptedException e) {
                        throw new IOException(e);
                    }
                }
            }
            waitingStreams.add(stream);
            return lastByte;
        }
    }
}

package de.mit.stackoverflow;

import java.io.IOException;
import java.io.InputStream;

public class SynchronizedStream extends InputStream {

    final private StreamSynchronizer synchronizer;

    protected SynchronizedStream(StreamSynchronizer synchronizer) {
        this.synchronizer = synchronizer;
    }

    @Override
    public void close() throws IOException {
        getSynchronizer().close(this);
    }

    public StreamSynchronizer getSynchronizer() {
        return synchronizer;
    }

    @Override
    public int read() throws IOException {
        return getSynchronizer().read(this);
    }
}

要回复问题请先登录或注册

JLayer同步

1 个回复

发起人

jlayer

问题状态

JLayer同步

与内容相关的链接

1 个回复

发起人

jlayer

问题状态