`

Lock和Condition实现线程通信(附阻塞队列的实例)

 
阅读更多

第一种情况:就使用单个Condition对象实现通信,方式同wait()和notify()

condition是await()和signal(),其中condition对象是通过lock.getCondition()获得的;

第二种情况:实现多路通信

下面是一个例子,来自于API中的Condition类,此例子实现了多路阻塞通信

public interface Condition

ConditionObject 监视器方法(waitnotifynotifyAll)分解成截然不同的对象,以便通过将这些对象与任意 Lock 实现组合使用,为每个对象提供多个等待 set(wait-set)。其中,Lock 替代了 synchronized 方法和语句的使用,Condition 替代了 Object 监视器方法的使用。

条件(也称为条件队列条件变量)为线程提供了一个含义,以便在某个状态条件现在可能为 true 的另一个线程通知它之前,一直挂起该线程(即让其“等待”)。因为访问此共享状态信息发生在不同的线程中,所以它必须受保护,因此要将某种形式的锁与该条件相关联。等待提供一个条件的主要属性是:以原子方式 释放相关的锁,并挂起当前线程,就像Object.wait 做的那样。

Condition 实例实质上被绑定到一个锁上。要为特定 Lock 实例获得 Condition 实例,请使用其 newCondition() 方法。

作为一个示例,假定有一个绑定的缓冲区,它支持 puttake 方法。如果试图在空的缓冲区上执行 take 操作,则在某一个项变得可用之前,线程将一直阻塞;如果试图在满的缓冲区上执行 put 操作,则在有空间变得可用之前,线程将一直阻塞。我们喜欢在单独的等待 set 中保存put 线程和 take 线程,这样就可以在缓冲区中的项或空间变得可用时利用最佳规划,一次只通知一个线程。可以使用两个Condition 实例来做到这一点。


ArrayBlockingQueue 类提供了这项功能,因此没有理由去实现这个示例类。)

Condition 实现可以提供不同于 Object 监视器方法的行为和语义,比如受保证的通知排序,或者在执行通知时不需要保持一个锁。如果某个实现提供了这样特殊的语义,则该实现必须记录这些语义。

注意,Condition 实例只是一些普通的对象,它们自身可以用作 synchronized 语句中的目标,并且可以调用自己的waitnotification 监视器方法。获取Condition 实例的监视器锁或者使用其监视器方法,与获取和该 Condition 相关的 Lock 或使用其 waitingsignalling 方法没有什么特定的关系。为了避免混淆,建议除了在其自身的实现中之外,切勿以这种方式使用Condition 实例。

除非另行说明,否则为任何参数传递 null 值将导致抛出 NullPointerException

实现注意事项

在等待 Condition 时,允许发生“虚假唤醒”,这通常作为对基础平台语义的让步。对于大多数应用程序,这带来的实际影响很小,因为Condition 应该总是在一个循环中被等待,并测试正被等待的状态声明。某个实现可以随意移除可能的虚假唤醒,但建议应用程序程序员总是假定这些虚假唤醒可能发生,因此总是在一个循环中等待。

三种形式的条件等待(可中断、不可中断和超时)在一些平台上的实现以及它们的性能特征可能会有所不同。尤其是它可能很难提供这些特性和维护特定语义,比如排序保证。更进一步地说,中断线程实际挂起的能力在所有平台上并不是总是可行的。

因此,并不要求某个实现为所有三种形式的等待定义完全相同的保证或语义,也不要求其支持中断线程的实际挂起。

要求实现清楚地记录每个等待方法提供的语义和保证,在某个实现不支持中断线程的挂起时,它必须遵从此接口中定义的中断语义。

由于中断通常意味着取消,而又通常很少进行中断检查,因此实现可以先于普通方法的返回来对中断进行响应。即使出现在另一个操作后的中断可能会释放线程锁时也是如此。实现应记录此行为。

分享到:
评论

相关推荐

    java阻塞队列实现原理及实例解析.docx

    阻塞队列的核心特性在于其在队列为空或满时能够自动阻塞线程,从而实现线程间的同步和通信。这种机制使得生产者和消费者线程可以高效地协同工作,而无需显式地使用锁和条件变量。 在Java中,自Java 5.0起,`java....

    java阻塞队列实现原理及实例解析

    阻塞队列的实现原理是基于锁机制和条件变量机制的,通过wait和notify方法来实现线程之间的同步。 阻塞队列与普通队列的不同在于,当队列是空的时候,从队列中获取元素的操作将会被阻塞,或者当队列满时,往队列里面...

    JavaLock与Condition的理解Reentran

    通过创建不同的Condition实例,可以实现不同条件下的线程通信。 六、实战技巧 1. 使用tryLock()避免死锁:在高并发环境中,可以先尝试获取锁,失败后再进行其他操作,减少死锁的风险。 2. 使用LockInterruptibly()...

    java中的Lock类和Condition类.docx

    - `newCondition()`: 创建一个新的Condition实例,可以用于实现线程间的精确通信。 3. **Condition类** - Condition接口允许我们创建和管理线程等待队列。每个Lock实例都可以创建一个或多个Condition实例,每个...

    linux上实现多进程和多线程实现同步互斥(源代码)

    - 使用条件变量实现线程间的协作,如生产者消费者模型。 - 实现读写锁,允许多个读取线程并行,写入线程独占。 - 应用信号量控制并发访问的资源数量。 总结,Linux上的多进程和多线程编程涉及复杂的同步互斥操作,...

    并发容器之ArrayBlockingQueue和LinkedBlockingQueue实现原理详解

    ArrayBlockingQueue内部使用数组存储元素,使用ReentrantLock来保证线程安全,使用Condition来实现可阻塞式的插入和删除元素操作。其主要属性包括: * items数组:用于存储队列元素 * takeIndex和putIndex:分别...

    java多线程加锁以及Condition类的使用实例解析

    该示例代码实现了一个阻塞队列,使用 ReentrantLock 和 Condition 来实现线程之间的同步。 二、Condition 类的使用 Condition 类是 Java 中的一个接口,提供了条件变量机制。Condition 变量可以用来实现线程之间的...

    Lock、Condition实现简单的生产者消费者模式示例

    在这个示例中,使用了Java的`java.util.concurrent.locks`包中的`Lock`接口和`Condition`接口来实现这一模式。`Lock`接口提供了比`synchronized`更精细的锁控制,而`Condition`接口则允许我们创建特定条件的等待队列...

    线程创建和线程间的通信

    4. 队列:包括阻塞队列(Blocking Queue)和生产者-消费者模型,线程可以在队列中放入或取出元素,达到同步和通信的目的。 5. 管道(Pipe)和通道(Channel):在某些系统中,线程可以通过管道或通道直接传递数据,...

    队列分享-易群1

    总的来说,`BlockingQueue`是Java并发编程中一个强大的工具,它简化了多线程环境下的同步和通信,提供了丰富的阻塞操作,以及良好的性能和线程安全性。通过合理利用`BlockingQueue`,我们可以构建高效、可靠的并发...

    C++-多线程编程总结-实例讲解.doc

    - **任务队列**:任务队列是实现并发的一个有效方式,它通常基于锁和条件变量(如C++的`std::mutex`和`std::condition_variable`)来同步生产者和消费者的活动。生产者线程将任务放入队列,而消费者线程负责取出并...

    多线程实例

    本实例主要探讨了内部锁(synchronized)、重入锁(ReentrantLock)、读写锁(ReadWriteLock)、Condition以及信号量(Semaphore)等与线程同步相关的概念及其原理。以下是对这些知识点的详细讲解: 1. 内部锁...

    多线程实验

    3. **线程同步控制**:利用synchronized、wait()、notify()和notifyAll()进行线程间的通信和同步,以及使用Lock和Condition来实现更复杂的同步策略。 实验内容涵盖了三个典型的多线程场景: 1. **象棋大师与多个...

    wait,notify等线程知识.pdf

    但Condition与特定的Lock关联,可以创建多个Condition实例,每个实例对应不同的等待队列,这样可以实现更精细的线程同步控制。 6. **线程同步的重要性**: 在多线程环境中,同步是必要的,以防止数据不一致性和竞...

    Java多线程编程总结

    - 阻塞队列:如ArrayBlockingQueue、LinkedBlockingQueue等实现线程间的异步通信。 - 阻塞栈:如LinkedTransferQueue实现阻塞队列功能的栈。 - 条件变量:Condition接口提供线程间的精确同步。 - 原子量:Atomic...

    Java多线程演示系统.zip

    此外, BlockingQueue是一种队列数据结构,它支持线程安全的插入和移除操作,常用于生产者消费者模型,实现线程间的通信和数据共享。 "Java多线程演示系统.pdf"可能涵盖了以上所有内容,并通过具体的代码示例来展示...

    Java线程类小结(附思维导图)

    - **条件变量(Condition)**:配合Lock实现等待/通知机制,比`synchronized`的`wait()`和`notify()`更灵活。 5. **线程池** - **Executor框架**:Java 5引入的线程池模型,提高了系统性能和管理线程的便利性。 ...

    locktest.zip

    本案例"locktest.zip"主要探讨了线程安全中的Lock机制,以及它与synchronized关键字的区别,并通过实例展示了Lock如何实现线程的等待通知和顺序执行。 首先,让我们理解什么是Lock。在Java中,`java.util....

Global site tag (gtag.js) - Google Analytics