Make test code thread stop if it's interrupted already

komamitsu · Apr 1, 2016 · f86bed7 · f86bed7
1 parent b87da21
commit f86bed7
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/test/java/org/komamitsu/fluency/FluencyTest.java b/src/test/java/org/komamitsu/fluency/FluencyTest.java
@@ -363,6 +363,11 @@ private void testFluencyBase(final FluencyFactory fluencyFactory, final Options
                     public void run()
                     {
                         for (int i = 0; i < reqNum; i++) {
+                            if (Thread.currentThread().isInterrupted()) {
+                                LOG.info("Interrupted...");
+                                break;
+                            }
+
                             if (options.failover) {
                                 if (i == reqNum / 2) {
                                     if (shouldFailOver.getAndSet(false)) {