Spring/spring-data-redis
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

DATAREDIS-843 - Polishing.

Browse Source 
Improve test stability to not concurrently create atomic counter instances.
This commit is contained in:
Mark Paluch
2018-07-24 16:25:44 +02:00
parent eff0d29723
commit c6ecd4603d
1 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/test/java/org/springframework/data/redis/support/atomic/RedisAtomicIntegerTests.java
View File

@@ -149,18 +149,17 @@ public class RedisAtomicIntegerTests extends AbstractRedisAtomicsTests {
@Test // DATAREDIS-108, DATAREDIS-843
public void testCompareSet() throws Exception {
final AtomicBoolean alreadySet = new AtomicBoolean(false);
final int NUM = 50;
final String KEY = getClass().getSimpleName() + ":atomic:counter";
final CountDownLatch latch = new CountDownLatch(NUM);
final AtomicBoolean failed = new AtomicBoolean(false);
AtomicBoolean alreadySet = new AtomicBoolean(false);
int NUM = 50;
String KEY = getClass().getSimpleName() + ":atomic:counter";
CountDownLatch latch = new CountDownLatch(NUM);
AtomicBoolean failed = new AtomicBoolean(false);
RedisAtomicInteger atomicInteger = new RedisAtomicInteger(KEY, factory);
for (int i = 0; i < NUM; i++) {
new Thread(() -> {
RedisAtomicInteger atomicInteger = new RedisAtomicInteger(KEY, factory);
try {
if (atomicInteger.compareAndSet(0, 1)) {
if (alreadySet.get()) {