FilesExpand file tree

master

/

NotifyVsNotifyAll.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

43 lines (40 loc) · 1.34 KB

master

/

NotifyVsNotifyAll.java

Copy path

Top

File metadata and controls

• Code
• Blame

43 lines (40 loc) · 1.34 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

package dev.wenbo.TIJ;

import java.util.Timer;

import java.util.TimerTask;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.TimeUnit;

public class NotifyVsNotifyAll {

public static void main(String[] args) throws InterruptedException {

ExecutorService exec= Executors.newCachedThreadPool();

for(int i=0;i<5;i++){

exec.execute(new Task());

}

exec.execute(new Task2());

Timer timer=new Timer();

timer.scheduleAtFixedRate(new TimerTask() {

boolean prod=true;

@Override

public void run() {

if(prod){

System.out.println("\nnotify()");

Task.blocker.prod();

prod=false;

}else{

System.out.println("\nnotifyAll()");

Task.blocker.prodAll();

prod=true;

}

}

}, 400,400);

TimeUnit.SECONDS.sleep(5);

timer.cancel();

System.out.println("\nTimer canceled");

TimeUnit.MILLISECONDS.sleep(500);

System.out.println("Task2.blocker.prodAll()");

Task2.blocker.prodAll();

TimeUnit.MILLISECONDS.sleep(500);

System.out.println("\nShutting down");

exec.shutdownNow();

}

}