自己写的数据缓冲池

0 0

自己写的数据缓冲池0

出于某个原因需要自己实现网络缓冲池的效果，用来缓存视频流数据的。想问一下这样的做法可不可行，不知道效率怎么样，是否合格。因为是缓存网络视频流数据，就担心性能和消耗问题，求指导。实现就两个方法，一个写一个读，为了模拟整个操作所以写了两个线程来执行。

public class TestByteBuffer {

	private ByteBuffer recBuffer = ByteBuffer.allocate(1024);

	/**
	 * @param args
	 * @throws InterruptedException
	 */
	public static void main(String[] args) throws InterruptedException {
		TestByteBuffer tbb = new TestByteBuffer();
		InData id = new InData(tbb.recBuffer);
		OutData od = new OutData(tbb.recBuffer);
		id.start();
		Thread.sleep(5);
		od.start();
		Thread.sleep(5000);
		id.setCycle(false);
		od.setCycle(false);
	}

}

class InData extends Thread {
	private String str = "LinkedList<ByteBuffer> recLL = new LinkedList<ByteBuffer>()";
	protected int i = 0;
	private ByteBuffer recBuffer;
	private int incomeSize;
	private byte[] ss = null;
	private boolean cycle = true;

	public InData(ByteBuffer recBuffer) {
		this.recBuffer = recBuffer;
	}

	@Override
	public void run() {
		System.out.println("input start");
		long st = System.currentTimeMillis();
		long et = 0;
		while (cycle) {
			ss = ("count " + i++ + " : " + str).getBytes();
			incomeSize = ss.length;
			if (incomeSize == 0) {
				return;
			}
			if (incomeSize > recBuffer.remaining()) {
				if (recBuffer.remaining() == 0) {
					recBuffer.position(0);
				} else {
					incomeSize = recBuffer.remaining();
				}
			}
			try {
				recBuffer.put(ss, 0, incomeSize);
			} catch (Exception e) {
				System.out.println("exception in InData");
				break;
			}
		}
		et = System.currentTimeMillis() - st;
		System.out.println("cycle " + i + " times in " + et);
		System.out.println("read : " + (i / et) + "/sec");
	}

	public boolean isCycle() {
		return cycle;
	}

	public void setCycle(boolean cycle) {
		this.cycle = cycle;
	}
}

class OutData extends Thread {
	private ByteBuffer recBuffer;
	private int writePosition;
	private int writeSize;
	private ByteBuffer sendBuffer = ByteBuffer.allocate(48);
	private boolean cycle = true;
	private int i = 0;

	public OutData(ByteBuffer recBuffer) {
		this.recBuffer = recBuffer;
	}

	@Override
	public void run() {
		System.out.println("output start");
		long st = System.currentTimeMillis();
		long et = 0;
		while (cycle) {
			i++;
			if (writePosition == recBuffer.limit()) {
				writePosition = 0;
				writeSize = sendBuffer.limit();
			} else {
				if ((writePosition + sendBuffer.limit()) > recBuffer.limit()) {
					writeSize = recBuffer.limit() - writePosition;
				} else {
					writeSize = sendBuffer.limit();
				}
			}
			try {
				System.arraycopy(recBuffer.array(), writePosition,
						sendBuffer.array(), 0, writeSize);
				System.out.println(new String(sendBuffer.array()));
			} catch (Exception e) {
				System.out.println("exception in OutData");
				e.printStackTrace();
				break;
			}
			// System.out.println(new String(sendBuffer.array()));
			writePosition += writeSize;
		}
		et = System.currentTimeMillis() - st;
		System.out.println("cycle " + i + " times in " + et);
		System.out.println("write : " + (i / et) + "/sec");
	}

	public boolean isCycle() {
		return cycle;
	}

	public void setCycle(boolean cycle) {
		this.cycle = cycle;
	}
}