测试并发应用（二）监控Phaser类

2022-05-11 01:05:35

声明：本文是《 Java 7 Concurrency Cookbook 》的第八章，作者： Javier Fernández González 译者：郑玉婷

监控Phaser类

Java 并发 API 提供的其中一个最复杂且强大的功能是使用 Phaser 类来执行同步phased任务。当有些任务可以分成步骤执行时，此机制是很有用的。Phaser类提供的同步线程机制是在每个步骤的末端，所以全部的线程都完成第一步后，才能开始执行第二步。

在这个指南，你将学习如何从Phaser类获取其状态信息。

准备

指南中的例子是使用Eclipse IDE 来实现的。如果你使用Eclipse 或者其他的IDE，例如NetBeans, 打开并创建一个新的java项目。

怎么做呢…

按照这些步骤来实现下面的例子：

01
//1.   创建一个类，名为 Task ，实现 Runnable 接口.

02

public class Task implements Runnable {

03
 
04
//2.   声明一个私有 int 属性，名为 time。

05

private int time;

06
 
07
//3.   声明私有 Phaser 属性，名为 phaser.

08

private Phaser phaser;

09
 
10
//4.   实现类的构造函数，初始其属性值。

11

public Task(int time, Phaser phaser) {

12

    this.time=time;

13

    this.phaser=phaser;

14
}

15
 
16
//5.   实现 run() 方法。首先，使用 arrive() 方法指示 phaser 属性任务开始执行了。

17
@Override

18

public void run() {

19
 
20

    phaser.arrive();

21
 
22
//6.   写信息到操控台表明阶段一开始，把线程放入休眠几秒，使用time属性来表明，再写信息到操控台表明阶段一结束，并使用 phaser 属性的 arriveAndAwaitAdvance() 方法来与剩下的任务同步。

23

System.out.printf("%s: Entering phase 1.\n",Thread. currentThread().getName());

24

try {

25

    TimeUnit.SECONDS.sleep(time);

26

} catch (InterruptedException e) {

27

    e.printStackTrace();

28
}

29

System.out.printf("%s: Finishing phase 1.\n",Thread. currentThread().getName());

30
phaser.arriveAndAwaitAdvance();

31
 
32
//7.    为第二和第三阶段重复第一阶段的行为。在第三阶段的末端使用 arriveAndDeregister()方法代替 arriveAndAwaitAdvance() 方法。

33

System.out.printf("%s: Entering phase 2.\n",Thread. currentThread().getName());

34

try {

35

    TimeUnit.SECONDS.sleep(time);

36

} catch (InterruptedException e) {

37

    e.printStackTrace();

38
}

39

System.out.printf("%s: Finishing phase 2.\n",Thread. currentThread().getName());

40
phaser.arriveAndAwaitAdvance();

41
 
42

System.out.printf("%s: Entering phase 3.\n",Thread. currentThread().getName());

43

try {

44

    TimeUnit.SECONDS.sleep(time);

45

} catch (InterruptedException e) {

46

    e.printStackTrace();

47
}

48

System.out.printf("%s: Finishing phase 3.\n",Thread. currentThread().getName());

49
 
50
phaser.arriveAndDeregister();

51
 
52
//8.   创建例子的主类通过创建一个类，名为 Main 并添加 main()方法。

53

public class Main {

54
 
55

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

56
 
57
//9.   创建新的有3个参与者的 Phaser 对象，名为 phaser。

58

Phaser phaser=new Phaser(3);

59
 
60
//10. 创建并运行3个线程来执行3个task对象。

61

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

62

    Task task=new Task(i+1, phaser);

63

    Thread thread=new Thread(task);

64

    thread.start();

65
}

66
 
67
//11.创建迭代10次的for循环，来学关于phaser对象的信息。

68

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

69
 
70
//12. 写关于 registered parties 的信息，phaser的phase，到达的parties, 和未到达的parties 的信息。

71

System.out.printf("********************\n");

72

System.out.printf("Main: Phaser Log\n");

73

System.out.printf("Main: Phaser: Phase: %d\n",phaser.getPhase());

74

System.out.printf("Main: Phaser: Registered Parties:%d\n",phaser.getRegisteredParties());

75

System.out.printf("Main: Phaser: Arrived Parties:%d\n",phaser.getArrivedParties());

76

System.out.printf("Main: Phaser: Unarrived Parties:%d\n",phaser.getUnarrivedParties());

77

System.out.printf("********************\n");

78
 
79
//13. 让线程休眠1秒，并合上类的循环。

80

TimeUnit.SECONDS.sleep(1);

81
}

82
}

83
}

它是如何工作的…

在这个指南，我们在 Task 类实现了 phased 任务。此 phased 任务有3个phases，并使用Phaser接口来与其他Task对象同步。当这些任务正在执行他们的phases时候，主类运行3个任务并打印关于phaser对象的状态信息到操控台。我们使用以下的方法来获取phaser对象的状态：

getPhase():此方法返回phaser 任务的 actual phase
getRegisteredParties(): 此方法返回使用phaser对象作为同步机制的任务数
getArrivedParties(): 此方法返回已经到达actual phase末端的任务数
getUnarrivedParties(): 此方法返回还没到达actual phase末端的任务数

以下的裁图展示了项目的部分输出：

参见

第三章，线程同步应用：运行阶段性并发任务

文章转自并发编程网-ifeve.com

码农公寓

监控Phaser类

相关文章