FilesExpand file tree

 master

/

NoSync.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

69 lines (56 loc) · 1.52 KB

 master

/

NoSync.java

Copy path

Top

File metadata and controls

• Code
• Blame

69 lines (56 loc) · 1.52 KB

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

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

48

49

50

51

52

53

54

55

56

57

58

59

60

61

62

63

64

65

66

67

68

69

package multithreading;

import java.util.concurrent.Callable;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.Future;

public class NoSync {

static class Value {

int value;

Value(int v){

this.value=v;

}

}

static class Adder implements Callable<Void>{

Value value;

Adder(Value v){

this.value=v;

}

public Void call() throws Exception{

for(int i=1;i<=10000;i++){

value.value = value.value + i;

}

return null;

}

}

static class Subtractor implements Callable<Void>{

Value value;

Subtractor(Value v){

this.value=v;

}

public Void call() throws Exception{

for(int i=1;i<=10000;i++){

value.value=value.value-i;

}

return null;

}

}

public static void main(String[] args) {

Value v = new Value(0);

ExecutorService es = Executors.newCachedThreadPool();

Adder a = new Adder(v);

Subtractor s = new Subtractor(v);

Future<Void> fa = es.submit(a);

Future<Void> fs = es.submit(s);

try{

fa.get();

fs.get();

}

catch(Exception e){

System.out.println(" got an "+ e);

}

finally{

es.shutdown();

}

System.out.println("Value after raw threading = "+v.value);

}

}