@Override
  @Test
  public void loadTest() throws Exception {
    prepareForLoadTest();

    readerThreads.linkToWriter(writerThreads);

    writerThreads.start(0, numKeys, NUM_THREADS);
    readerThreads.start(0, numKeys, NUM_THREADS);

    writerThreads.waitForFinish();
    readerThreads.waitForFinish();

    assertEquals(0, writerThreads.getNumWriteFailures());
    assertEquals(0, readerThreads.getNumReadFailures());
    assertEquals(0, readerThreads.getNumReadErrors());
    assertEquals(numKeys, readerThreads.getNumUniqueKeysVerified());
  }
A write/read/verify load test on a mini HBase cluster. Tests reading and writing at the same
time.
hbase-diagnostics/src/test/java/org/apache/hadoop/hbase/util/TestMiniClusterLoadParallel.java