Чистый код. Создание, анализ и рефакторинг

05: import org.junit.Test;

06:

07: public class ClassWithThreadingProblemTest {

08:     @Test

09:     public void twoThreadsShouldFailEventually() throws Exception {

10:         final ClassWithThreadingProblem classWithThreadingProblem

                = new ClassWithThreadingProblem();

11:

12:         Runnable runnable = new Runnable() {

Листинг А.2 (продолжение)

13:             public void run() {

14:                 classWithThreadingProblem.takeNextId();

15:             }

16:         };

17:

18:         for (int i = 0; i < 50000; ++i) {

19:             int startingId = classWithThreadingProblem.lastId;

20:             int expectedResult = 2 + startingId;

21:

22:             Thread t1 = new Thread(runnable);

23:             Thread t2 = new Thread(runnable);

24:             t1.start();

25:             t2.start();

26:             t1.join();

27:             t2.join();

28:

29:             int endingId = classWithThreadingProblem.lastId;

30:

31:             if (endingId != expectedResult)

32:                 return;

33:         }

34:

35:         fail("Should have exposed a threading issue but it did not.");

36:     }

37: }