Задача, такая: нужно принять по UDP пакеты на два сокета и передать их в другой(общий) поток. Выбрал следующий путь: принимаю пакеты-получаю объекты-и сериализую их в общий поток! Для передачи в общий поток использую PipedOutputStream и PipedInputStream. Для сериализации ObjectOutputStream и ObjectInputStream. Но возникла проблема, когда кидаю из двух сокетов в один поток java.io.OptionalDataException. Вопрос, как мне лучше разделить объекты в ObjectInputStream, передаваемые в один поток и возможно ли это вообще? Для одного сокета все работает!

Спасибо! забыл указать, что сокеты находятся в разных потоках, они принимают пакет, создают объект и сериализуют его в PipedOutputStream, причем эти два потока используют один и тот же PipedOutputStream. А в третьем потоке принимаю в PipedInputStream и пытаюсь его обработать!

Спасибо! забыл указать, что сокеты находятся в разных потоках, они принимают пакет, создают объект и сериализуют его в PipedOutputStream, причем эти два потока используют один и тот же PipedOutputStream. А в третьем потоке принимаю в PipedInputStream и пытаюсь его обработать! Как я понял вы предлагаете каждому сокету передать поток который и будет синхронизовано кидать сериализованные объекты в PipedOutputStream?

BlazkowiczЭти данные помещаются в очередь. Это очень быстрая операция.
Отдельный поток читает из очереди. Так! В потоке каждого сокета храним очередь?!! А отдельный поток будет читать эти очереди??!! Тогда вопрос каким образом оптимальнее(быстрее) проводить эту пердачу? Я вот передаю так: private void messageToObjectOutput(Message mes) throws IOException {
ObjectOutputStream oos = new ObjectOutputStream(pout);
synchronized(mes) {
oos.writeObject(mes);
oos.flush();
pout.flush();
}
}
pout это PipedOutputStream

а принимаю : ObjectInputStream ois = new ObjectInputStream(pin);
Message mes = (Message)ois.readObject(); pin PipedInputStream