suspension(要等到我准备好噢)
请求对象
public class Request {
private final String name;
public Request(String name) {
this.name = name;
}
public String getName() {
return name;
}
public String toString() {
return "[ Request " + name + " ]";
}
}
工作缓存器
public class RequestQueue {
//采用LinkedList 保存客户请求
private final LinkedList queue = new LinkedList();
//服务器获取请求
//保证同时只一个服务器执行这个方法
public synchronized Request getRequest() {
//当客户请求队列为空时等待
while (queue.size() <= 0) {
try {
wait();//等到客户添加请求
} catch (InterruptedException e) {
}
}
return (Request)queue.removeFirst();
}
//客户添加请求
//保证同时只一个客户执行这个方法
public synchronized void putRequest(Request request) {
queue.addLast(request);
notifyAll();//唤醒wait()方法,执行程序
}
}
工作缓存器jdk1.5新特性实现
public class RequestQueue {
private final LinkedList queue = new LinkedList();
private Lock lock = new ReentrantLock();
private Condition serverCondition = lock.newCondition();
private Condition clientCondition = lock.newCondition();
public Request getRequest() {
lock.lock();
try {
while (queue.size() <= 0) {
//类似wait();
serverCondition.await();
}
} catch (InterruptedException e) {
} finally {
lock.unlock();
}
return (Request) queue.removeFirst();
}
public void putRequest(Request request) {
lock.lock();
try {
queue.addLast(request);
//类似notifyAll();
clientCondition .signalAll();
} finally {
lock.unlock();
}
}
}
工作缓存器jdk1.5新特性实现
public class NewRequestQueue {
//一个特殊的Queue下面有详细的说明
private final static BlockingQueue<Request> basket = new ArrayBlockingQueue<Request>(
10);;
public Request getRequest() {
try {
return basket.take();
} catch (Exception e) {
throw new RuntimeException(e);
}
}
public void putRequest(Request request) {
try {
basket.put(request);
} catch (Exception e) {
throw new RuntimeException(e);
}
}
}
BlockingQueue 是一种特殊的Queue，若BlockingQueue 是空的，从
BlockingQueue 取东西的操作将会被阻断进入等待状态直到BlocingkQueue 进
了新货才会被唤醒。同样，如果BlockingQueue 是满的任何试图往里存东西的
操作也会被阻断进入等待状态，直到BlockingQueue 里有新的空间才会被唤醒
继续操作。BlockingQueue 提供的方法主要有：
add(anObject): 把anObject 加到BlockingQueue 里，如果
BlockingQueue 可以容纳返回true，否则抛出IllegalStateException 异常。
offer(anObject)：把anObject 加到BlockingQueue 里，如果
BlockingQueue 可以容纳返回true，否则返回false。
put(anObject)：把anObject 加到BlockingQueue 里，如果BlockingQueue
没有空间，调用此方法的线程被阻断直到BlockingQueue 里有新的空间再继
续。
poll(time)：取出BlockingQueue 里排在首位的对象，若不能立即取出可
等time 参数规定的时间。取不到时返回null。
take()：取出BlockingQueue 里排在首位的对象，若BlockingQueue 为
空，阻断进入等待状态直到BlockingQueue 有新的对象被加入为止。
根据不同的需要 BlockingQueue 有4 种具体实现：
ArrayBlockingQueue：规定大小的BlockingQueue，其构造函数必须带
一个int 参数来指明其大小。其所含的对象是以FIFO（先入先出）顺序排序
的。
LinkedBlockingQueue：大小不定的BlockingQueue，若其构造函数带一
个规定大小的参数，生成的BlockingQueue 有大小限制，若不带大小参数，
所生成的BlockingQueue 的大小由Integer.MAX_VALUE 来决定。其所含的
对象是以FIFO（先入先出）顺序排序的。LinkedBlockingQueue 和
ArrayBlockingQueue 比较起来，它们背后所用的数据结构不一样，导致
LinkedBlockingQueue 的数据吞吐量要大于ArrayBlockingQueue，但在线程
数量很大时其性能的可预见性低于ArrayBlockingQueue。
PriorityBlockingQueue：类似于LinkedBlockingQueue，但其所含对象的
排序不是FIFO，而是依据对象的自然排序顺序或者是构造函数所带的
Comparator 决定的顺序。
SynchronousQueue：特殊的BlockingQueue，对其的操作必须是放和取
交替完成的。
客户线程
public class ClientThread extends Thread {
private Random random;
private RequestQueue requestQueue;
public ClientThread(RequestQueue requestQueue, String name, long seed) {
super(name);
this.requestQueue = requestQueue;
this.random = new Random(seed);
}
public void run() {
for (int i = 0; i < 10000; i++) {
Request request = new Request("No." + i);
System.out.println(Thread.currentThread().getName() + " requests " + request);
//放入请求
requestQueue.putRequest(request);
try {
Thread.sleep(random.nextInt(1000));
} catch (InterruptedException e) {
}
}
}
}
服务器线程
public class ServerThread extends Thread {
private Random random;
private RequestQueue requestQueue;
public ServerThread(RequestQueue requestQueue, String name, long seed) {
super(name);
this.requestQueue = requestQueue;
this.random = new Random(seed);
}
public void run() {
for (int i = 0; i < 10000; i++) {
Request request = requestQueue.getRequest();
System.out.println(Thread.currentThread().getName() + " handles " + request);
try {
Thread.sleep(random.nextInt(1000));
} catch (InterruptedException e) {
}
}
}
}
测试类
public class Main {
public static void main(String[] args) {
RequestQueue requestQueue = new RequestQueue();
new ClientThread(requestQueue, "Alice", 3141592L).start();
new ServerThread(requestQueue, "Bobby", 6535897L).start();
}
}
分享到：
- 2009-07-09 11:19
- 浏览 1754
- 评论(2)
- 论坛回复 / 浏览 (1 / 2512)
- 查看更多
相关推荐
书中包含Java线程的介绍导读、12个重要的线程设计模式和全书总结以及丰富的附录内容。第一章相关线程设计模式的介绍，都举一反三使读者学习更有效。最后附上练习问题，让读者可以温故而知新，能快速地吸收书中的...
目录： 漫谈UML Introduction 1 Java语言的线程 Introduction 2 多线程...总结 多线程程序设计的模式语言 附录A 练习问题的解答 附录B Java的内存模型 附录C Java线程的优先级 附录D 线程相关的主要API 附录E 参考文献
在多线程环境中，确保数据的一致性和程序的正确性非常重要，因此多线程模式对于处理并发问题尤为重要。 - **Guarded Suspension**：保护性暂停模式，允许线程等待条件满足后再继续执行。 - **Producer-Consumer**：...
│ 高并发编程第二阶段41讲、多线程设计模式内容回顾与总结.mp4 │ 高并发编程第二阶段42讲、ClassLoader课程大纲介绍.mp4 │ 高并发编程第二阶段43讲、类加载的过程以及类主动使用的六种情况详细介绍.mp4 │ 高...
│ 高并发编程第二阶段41讲、多线程设计模式内容回顾与总结.mp4 │ 高并发编程第二阶段42讲、ClassLoader课程大纲介绍.mp4 │ 高并发编程第二阶段43讲、类加载的过程以及类主动使用的六种情况详细介绍.mp4 │ 高...
28. **守卫条件模式\(Guarded Suspension\)**：等待某个条件满足时再继续执行，常用于多线程的同步。 29. **生产者消费者模式\(Producer Consumer\)**：一个生产者和多个消费者之间的资源分配问题，通常用信号量...
### 设计模式笔记 #### 一、引言 设计模式是一种在特定情境下解决软件设计问题的标准化解决方案。它是从无数编程实践中提炼出来的精华，帮助开发者更好地理解和应对复杂的问题。在学习设计模式的过程中，我们通常...
在这个部分，作者提供了多种设计模式来解决实际并发问题。从监控任务的生命周期管理到单线程执行模式，从读写锁分离到不可变对象设计，再到`Future`和`Guarded Suspension`模式，这些模式能够帮助读者构建出既高效又...
并发编程笔记中的知识点涵盖了保护性暂停模式（Guarded Suspension Design Pattern）的定义、实现与分析，以及在Java中如何通过GuardedObject对象来实现多线程间的结果传递和超时处理。以下是详细的知识点梳理： 1....
7. **状态机设计**：为了实现挂起和恢复，程序可能使用了状态机的设计模式，定义了各种状态（如运行、挂起、恢复），并通过转换条件来控制流程。 8. **测试与调试**：源码可能包含单元测试和调试工具，用于验证挂起...
8. **Guarded Suspension 模式**：这是一种设计模式，通常使用`wait()`和`notify()`方法来协调线程间的执行顺序，确保特定条件满足时线程才能继续执行。 9. **Double-Check Locking（双重检查锁定）**：这是一种...
- **多线程设计模式**： - **Future**：支持异步处理，通过`FutureTask`实现。 - **Master-Worker**：适用于可以分解的任务，提高并行处理效率。 - **Guarded Suspension**：在没有足够的资源时暂停执行，避免...
这两本书结合阅读，可以帮助Java开发者从理论到实践全面掌握并发编程，避免常见的陷阱，提升多线程应用程序的效率和可靠性。无论是对并发编程有初步了解的新手，还是希望深化理解的老手，都能从中受益匪浅。通过阅读...
- 当需要提高多线程环境下的性能时，因为不可变对象可以安全地在多个线程之间共享。 #### 1.4 标记接口（Marker Interface） **使用：** 标记接口是一种特殊的接口类型，它没有任何方法声明。它主要用于表示某种...