What is the equivalent of poll or dequeue method about tape HOT 4 CLOSED

Exception in thread "Thread-3" Exception in thread "Thread-4" com.squareup.tape.FileException: Failed to peek.
at com.squareup.tape.FileObjectQueue.peek(FileObjectQueue.java:59)
at com.example.FileQueueConsumer.run(FileQueueConsumer.java:19)
at java.lang.Thread.run(Thread.java:745)
Caused by: java.io.StreamCorruptedException: invalid type code: AC
at java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1381)
at java.io.ObjectInputStream.readUnshared(ObjectInputStream.java:463)
at com.squareup.tape.SerializedConverter.deserialize(SerializedConverter.java:27)
at com.squareup.tape.SerializedConverter.from(SerializedConverter.java:37)
at com.squareup.tape.SerializedConverter.from(SerializedConverter.java:20)
at com.squareup.tape.FileObjectQueue.peek(FileObjectQueue.java:57)
... 3 more
Here is what I did?
Create producer1, producer2,consumer1,consumer2 all on same FileObjectQueue. I believe there is some issue in multithreading handling.

Looks relevant to this
http://stackoverflow.com/questions/3182240/java-io-streamcorruptedexception-invalid-type-code-ac

from tape.

FileObjectQueue is not thread safe.

from tape.

Is there a threadsafe file based queue in the current api?

from tape.

No

On Sat, Aug 6, 2016, 9:51 AM Rohit Verma [email protected] wrote:

Is there a threadsafe file based queue in the current api?

—
You are receiving this because you are subscribed to this thread.
Reply to this email directly, view it on GitHub
#87 (comment), or mute
the thread
https://github.com/notifications/unsubscribe-auth/AAEEEQuG8KCB5YO4S626x0UUjG5YRgbfks5qdJFJgaJpZM4JeJwv
.

from tape.