From b9df357760abc3d868c69c0c9b9b969441cb4bce Mon Sep 17 00:00:00 2001
From: Nikita <abracham.mitchell@gmail.com>
Date: Thu, 17 Dec 2015 15:30:58 +0300
Subject: [PATCH] RedissonSemaphoreTest improvements

---
 .../org/redisson/RedissonSemaphoreTest.java   | 24 +++++++++++++++----
 1 file changed, 19 insertions(+), 5 deletions(-)

diff --git a/src/test/java/org/redisson/RedissonSemaphoreTest.java b/src/test/java/org/redisson/RedissonSemaphoreTest.java
index 7fbffc7c8..dc322c1b1 100644
--- a/src/test/java/org/redisson/RedissonSemaphoreTest.java
+++ b/src/test/java/org/redisson/RedissonSemaphoreTest.java
@@ -44,14 +44,21 @@ public class RedissonSemaphoreTest extends BaseConcurrentTest {
     public void testBlockingNAcquire() throws InterruptedException {
         RSemaphore s = redisson.getSemaphore("test");
         s.setPermits(5);
-        s.acquire(2);
+        s.acquire(3);
 
         Thread t = new Thread() {
             @Override
             public void run() {
                 RSemaphore s = redisson.getSemaphore("test");
                 try {
-                    Thread.sleep(1000);
+                    Thread.sleep(500);
+                } catch (InterruptedException e) {
+                    // TODO Auto-generated catch block
+                    e.printStackTrace();
+                }
+                s.release();
+                try {
+                    Thread.sleep(500);
                 } catch (InterruptedException e) {
                     // TODO Auto-generated catch block
                     e.printStackTrace();
@@ -60,7 +67,7 @@ public class RedissonSemaphoreTest extends BaseConcurrentTest {
             }
         };
 
-        assertThat(s.availablePermits()).isEqualTo(3);
+        assertThat(s.availablePermits()).isEqualTo(2);
         t.start();
 
         s.acquire(4);
@@ -71,14 +78,21 @@ public class RedissonSemaphoreTest extends BaseConcurrentTest {
     public void testTryNAcquire() throws InterruptedException {
         RSemaphore s = redisson.getSemaphore("test");
         s.setPermits(5);
-        assertThat(s.tryAcquire(2)).isTrue();
+        assertThat(s.tryAcquire(3)).isTrue();
 
         Thread t = new Thread() {
             @Override
             public void run() {
                 RSemaphore s = redisson.getSemaphore("test");
                 try {
-                    Thread.sleep(1000);
+                    Thread.sleep(500);
+                } catch (InterruptedException e) {
+                    // TODO Auto-generated catch block
+                    e.printStackTrace();
+                }
+                s.release();
+                try {
+                    Thread.sleep(500);
                 } catch (InterruptedException e) {
                     // TODO Auto-generated catch block
                     e.printStackTrace();