@Test
@SuppressWarnings("unchecked")
public void testConcurrentRequestRecycle() throws ExecutionException, InterruptedException, IOException {

	int numConcurrentTasks = 128;
	int numBuffersToRequestPerTask = 1024;
	localBufferPool.setNumBuffers(numConcurrentTasks);
	Future<Boolean>[] taskResults = new Future[numConcurrentTasks];
	for (int i = 0; i < numConcurrentTasks; i++) {
		taskResults[i] = executor.submit(new BufferRequesterTask(localBufferPool, numBuffersToRequestPerTask));
	}
	for (int i = 0; i < numConcurrentTasks; i++) {
		assertTrue(taskResults[i].get());
	}
}