import org.nustaq.serialization.simpleapi.DefaultCoder; //导入依赖的package包/类
public void fstTest3() throws InterruptedException {
	DefaultCoder c = new DefaultCoder();
	Random r = new Random();
	CountDownLatch l = new CountDownLatch(1);
	for (int i = 0; i < 100; i++) {
		Thread t = new Thread() {
			@Override
			public void run() {
				try {
					l.await();
					long a = r.nextLong();
					byte[] buf = c.toByteArray(a);
					long b = (long) c.toObject(buf);
					Assert.assertEquals(a, b);
				} catch (InterruptedException e) {
				}
			}
		};
		t.start();
	}

	l.countDown();
	Thread.sleep(10000);
}
 

import org.nustaq.serialization.simpleapi.DefaultCoder; //导入依赖的package包/类
public void carBenchInternDefault(boolean shared) throws Exception {
    DefaultCoder coder =new DefaultCoder(shared,
            Car.class, CarBench.Engine.class, CarBench.Model.class,
            CarBench.Accel.class, CarBench.PerformanceFigures.class,
            CarBench.FueldData.class, CarBench.OptionalExtras.class);

    byte arr[] = new byte[10000];

    System.out.println("-----");
    Object car = setupSampleObject();
    Object deser = null;

    for (int i=0; i<10; i++) {
        deser = onhbench(car, coder, arr, 0);
    }
    assertTrue(DeepEquals.deepEquals(car, deser));
}
 

import org.nustaq.serialization.simpleapi.DefaultCoder; //导入依赖的package包/类
public RemoteFastSerializingSerde(final boolean shared, final Class<E> type) {
    if (Serializable.class.isAssignableFrom(type)) {
        this.coder = new DefaultCoder(shared, type);
    } else {
        this.coder = new DefaultCoder(shared);
    }
}
 

import org.nustaq.serialization.simpleapi.DefaultCoder; //导入依赖的package包/类
public FSTLongOffheapMap(long sizeBytes, int numberOfElems) {
    super(8, sizeBytes, numberOfElems, new DefaultCoder());
}
 

import org.nustaq.serialization.simpleapi.DefaultCoder; //导入依赖的package包/类
protected FSTCoder createCoder() {
    return new DefaultCoder();
}
 

import org.nustaq.serialization.simpleapi.DefaultCoder; //导入依赖的package包/类
/**
 *
 * @param keyLen - maximum len of a key
 * @param sizeMemBytes - size of memory (not bigger than OS heap
 * @param numberOfEleems - estimation on number of key-value pairs (autogrow, just educated guess)
 */
public FSTUTFStringOffheapMap(int keyLen, long sizeMemBytes, int numberOfEleems) {
    super(keyLen, sizeMemBytes, numberOfEleems, new DefaultCoder());
}
 

import org.nustaq.serialization.simpleapi.DefaultCoder; //导入依赖的package包/类
/**
 *
 * @param keyLen - maximum len of a key
 * @param sizeMemBytes - size of memory (not bigger than OS heap
 * @param numberOfEleems - estimation on number of key-value pairs (autogrow, just educated guess)
 */
public FSTAsciiStringOffheapMap(int keyLen, long sizeMemBytes, int numberOfEleems) {
    super(keyLen, sizeMemBytes, numberOfEleems, new DefaultCoder());
    tmpKey = new LeftCutStringByteSource(null,0,keyLen);
}