FilesExpand file tree

 master

/

EvenChecker.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

32 lines (31 loc) · 911 Bytes

 master

/

EvenChecker.java

Copy path

Top

File metadata and controls

• Code
• Blame

32 lines (31 loc) · 911 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

//: concurrency/EvenChecker.java

import java.util.concurrent.*;

public class EvenChecker implements Runnable {

private IntGenerator generator;

private final int id;

public EvenChecker(IntGenerator g, int ident) {

generator = g;

id = ident;

}

public void run() {

while(!generator.isCanceled()) {

int val = generator.next();

if(val % 2 != 0) {

System.out.println(val + " not even!");

generator.cancel(); // Cancels all EvenCheckers

}

}

}

// Test any type of IntGenerator:

public static void test(IntGenerator gp, int count) {

System.out.println("Press Control-C to exit");

ExecutorService exec = Executors.newCachedThreadPool();

for(int i = 0; i < count; i++)

exec.execute(new EvenChecker(gp, i));

exec.shutdown();

}

// Default value for count:

public static void test(IntGenerator gp) {

test(gp, 10);

}

} ///:~