多线程程序设计学习（4）guarded suspension模式

Guarded Suspension【生产消费者模式】

一:guarded suspension的参与者
--->guardedObject(被防卫)参与者
1.1该参与者拥有一个被防卫的方法（getRequest）,如果警戒条件达成，则执行。警戒条件不达成，则线程进入wait set
1.2该参与者还拥有一个改变参与者状态的方法（putRequest）。参与者的状态影响着警戒条件的是否达成。

--->该模式的角色：生产端线程，消费端线程，传递数据的摇篮（被防卫的参与者）

二：guarded suspension模式什么时候使用
--->适合交易系统使用。客户端下单，服务端处理订单。高并发，大量数据处理的模式，增强服务的吞吐量

三：guarded suspension思考
--->与该模式共通的三个特征
3.1:有循环存在
3.2:有条件测试
3.3:有因某种原因的等待

---> guarded wait 被阻断而等待
等待端范例：
while(条件){
wait();
}
唤醒端范例：
条件=true
notifyAll();
---> busy wait 忙碌地等待
yield，尽可能把优先级交给其他线程，那个线程调用此方法，那个线程暂时一次让出CPU调度权。至于能否暂停，实际看cpu是否去掉别的线程。我主动放弃一次，至于cpu走不走，看cpu的。yield不会解除锁定，所以这段代码不可写在snychronized里。而ready字段必须声明成volatile
等待端范例：
while(ready){
Thead.yield();
}
唤醒端范例：
ready=true

---> spin lock 旋转而锁定
旋转而锁定的意思，表现出条件成立前while循环不断"旋转"的样子，spin lock有时意思与guarded wait相同，有时则与busy wait相同。另外，有时候则是指一开始使用busy wait ,之后再切换成guarded wait方式。另外有些硬件实现的同步机制

--->polling
" 进行舆论调查"的意思，反复检查某个事件是否发生，当发生时就进行对应的处理。

模仿队列（传递数据）

package com.yeepay.sxf.thread3;

import java.util.Random;

/**
* 测试类
* @author sxf
*
*/
public class Test {

public static void main(String[] args) {
//声明一个队列
RequestEntryQueue requestEntryQueue=new RequestEntryQueue();
//声明两个生产者线程
Thread clientThread1=new Thread(new ClientThread(requestEntryQueue, new Random(), "QQ客户端"));
Thread clientThread2=new Thread(new ClientThread(requestEntryQueue, new Random(), "ALIBABA客户端"));
//声明三个消费者线程
Thread serviceThread1=new Thread(new ServiceThread(requestEntryQueue, new Random(), "易宝支付"));
Thread serviceThread2=new Thread(new ServiceThread(requestEntryQueue, new Random(), "支付宝"));
Thread serviceThread3=new Thread(new ServiceThread(requestEntryQueue, new Random(), "财付通"));
//开启线程
clientThread1.start();
clientThread2.start();

serviceThread1.start();
serviceThread2.start();
serviceThread3.start();

}
}

View Code