Распараллелить быструю сериализацию Java

Question

Это первый раз, когда я работаю с потоками в Java. Я пытаюсь распараллелить быструю сериализацию. Но я получаю следующую ошибку:

Exception in thread "pool-1-thread-1" java.lang.RuntimeException: Class org.nustaq.serialization.FSTObjectOutput does not implement Serializable or externalizable

Так как правильно распараллелить быструю сериализацию? Где моя ошибка?

Вот мой управляемый класс:

public class RunnableTestClass implements Serializable, Runnable {

FSTObjectOutput out;
ObjectOutputStream stream;
private long a,b,c,d,e,f,g,h;
public RunnableTestClass(long i, ThreadLocal<FSTConfiguration> conf) throws Exception {
    a = i;
    //some more
    stream = new ObjectOutputStream(new FileOutputStream("out/FST.ser_parallel"));
    out = conf.get().getObjectOutput(stream);
}

@Override
public void run() {
    try {
        out.writeObject(this, TestClass.class);
        out.flush();
        stream.close();
    } catch (IOException e) {
        System.out.println(e);
    }
}

И вот мой главный:

public class Test {

public static FSTConfiguration[] configurations = new FSTConfiguration[4];
public static ThreadLocal<FSTConfiguration> conf = new ThreadLocal<FSTConfiguration>() {
    @Override
    protected FSTConfiguration initialValue() {
        return configurations[((int) (Thread.currentThread().getId() % configurations.length))];
    }
};
static {
    for (int i = 0; i < configurations.length; i++) {
        configurations[i] = FSTConfiguration.createDefaultConfiguration();
    }
}

public static void main(String [ ] args) {

    conf.get().registerClass(TestClass.class);
    conf.get().setShareReferences(false);

    ExecutorService executor = Executors.newFixedThreadPool(4);

    try {
        for (int i = 0; i < 10; i++) {
            Runnable worker = new RunnableTestClass(i, conf);
            executor.execute(worker);
        }
        executor.shutdown();
    } catch (Exception e) {
        System.out.println(e);
    }
}

Спасибо за вашу помощь.

Answer 1

Ошибка состояла в том, что я пытаюсь сериализовать ObjectOutput в моем Runnable Class. Я исправил это следующим образом:

public class RunnableTestClass implements Serializable, Runnable {

private FSTObjectOutput out;
private ObjectOutputStream stream;
private TestClass object;

public RunnableTestClass(long i, ThreadLocal<FSTConfiguration> conf) throws Exception {
    object = new TestClass(i);
    stream = new ObjectOutputStream(new FileOutputStream("out/FST.ser_parallel"));
    out = conf.get().getObjectOutput(stream);
}

@Override
public void run() {
    try {
        out.writeObject(object, TestClass.class);
        out.flush();
        stream.close();
    } catch (IOException e) {
        System.out.println(e);
    }
}

}

Поэтому я сериализую только объект "объект".