@Override
          public Object call() throws CacheException {
            if (opThreads == null) {
              return false;
            }
            for (final Thread opThread : opThreads) {
              if (((RunOp) opThread).getNumOpsPerformed() == 0) {
                return false;
              }
            }
            return true;
          }
Tests the Blokcing HARegionQueue by doing concurrent put /remove / take / peek , batch peek
operations in multiple regions. The test will have take/remove occuring in all the VMs. This
test is targetted to test for hang or exceptions in blocking queue.
geode-core/src/distributedTest/java/org/apache/geode/internal/cache/ha/HARegionQueueDUnitTest.java