Java线程间通讯

考虑经典的排队问题，其中一个线程正在生产一些数据，另一个是消费它。为了使问题更有趣，假设生产者必须等待，直到它会产生更多的数据消费完毕之前。

在一个轮询系统，消费者会浪费大量的CPU周期，而它等待着生产者生产。一旦生产结束了，就开始轮询，浪费更多的CPU周期等待消费者??完成，依此类推。显然，这种情况是不希望的。

为了避免轮询，Java包括通过下面的方法优雅的进程间通信机制：

wait( ): 这个方法告诉调用线程放弃监视器和进入睡眠状态，直到其他线程进入同一监视器和调用notify（）。
notify( ): 这种方法唤醒第一个线程调用wait（）在同一个对象上。
notifyAll( ): 这种方法唤醒所有调用wait（）的同一个对象上的线程。最高优先级的线程将首先运行。

这些方法被实现为final的方法在Object，因此所有的类都有它们。这三种方法都只能从一个同步的上下文中被调用。

这些方法的对象中声明。各种形式的wait( ) 存在，使可以指定一段时间等待。

例子：

下面的示例程序包括四个类：Q，想同步队列，Producer，也就是生产队列的条目线程对象;Consumer,即消耗队列的条目线程对象和PC，tiny类创建一个Q，生产者和消费者。

写这个程序在Java中正确的方法是使用wait()和notify()方法，以在两个方向的信号，如下所示：

Put: 1
Got: 1
Put: 2
Got: 2
Put: 3
Got: 3
Put: 4
Got: 4
Put: 5
Got: 5

时间： 2024-08-02 22:01:32

Java线程间通讯的相关文章

Java 线程间通讯

/* 线程间通讯: 多个线程在处理同一资源,但是任务却不同. */ package com.cwcec.test; class Input implements Runnable { Resource r; public Input(Resource r) { this.r = r; } public void run() { int x = 0; while(true) { synchronized (r) { if(x == 0) { r.name = "Mike"; r.sex

iOS开发多线程-线程间通讯

一.NSThread 线程间的通讯 1 - (void)demoAboutNSThread 2 { 3 NSLog(@"demoAboutNSThread %@", [NSThread currentThread]); 4 NSThread * thread = [[NSThread alloc] initWithTarget:self selector:@selector(longTimeOperation) object:nil]; 5 [thread start]; 6 } 7

线程间通讯

线程间通讯:把一个线程中计算的结果传递到另一个线程中使用. 示例场景:子线程下载网络图片,回主线程更新UI. NSThread示例代码: 1 - (void)viewDidLoad { 2 [super viewDidLoad]; 3 4 // 子线程下载网络数据 5 [self performSelectorInBackground:@selector(downloadImage) withObject:nil]; 6 } 7 8 // 加载网络数据,耗时操作,在子线程中进行 9 - (voi

iOS--多线程之线程间通讯

线程间通讯一.NSThread 1.简单说明 ①线程间通信:在1个进程中,线程往往不是孤立存在的,多个线程之间需要经常进行通信 ②线程间通信的体现 1个线程传递数据给另1个线程在1个线程中执行完特定任务后,转到另1个线程继续执行任务 ③线程间通信常用方法 // waitUntilDone的含义: // 如果传入的是YES: 那么会等到主线程中的方法执行完毕, 才会继续执行下面其他行的代码 // 如果传入的是NO: 那么不用等到主线程中的方法执行完毕, 就可以继续执行下面其他行的低吗 /* *

JAVA线程间共享变量

import java.util.HashMap; import java.util.Map; import java.util.Random; public class ThreadScopeShareData { static Map<Thread, Integer> dataMap = new HashMap<Thread, Integer>(); public static void main(String[] args) { for (int i = 0; i <

Java——线程间通信问题

wait和sleep区别: 1.wait可以指定时间可以不指定. sleep必须指定时间. 2.在同步时,对cpu的执行权和锁的处理不同. wait:释放执行权,释放锁. sleep:释放执行权,不释放锁. /* * 等待/唤醒机制 * 设计的方法: * 1.wait():让线程处于等待状态,被wait的线程会被存储到线程池中. * 2.notify():唤醒线程池中的一个线程(任意) * 3.notifyAll():唤醒线程池中的所有线程. * 这些方法都必须定义

C#线程间通讯

using System;using System.Text;using System.Windows.Forms;using System.Threading; namespace 线程间通讯{ public partial class Form1 : Form { public Form1() { InitializeComponent(); } //1.创建Invoke函数,大致如下:

说说Java线程间通信

序言正文 [一] Java线程间如何通信? 线程间通信的目标是使线程间能够互相发送信号,包括如下几种方式: 1.通过共享对象通信线程间发送信号的一个简单方式是在共享对象的变量里设置信号值:线程A在一个同步块里设置boolean型成员变量hasDataToProcess为true,线程B也在同步块里读取hasDataToProcess这个成员变量:线程A和B必须获得指向一个MySignal共享实例的引用,以便进行通信:如果它们持有的引用指向不同的MySingal实例,那么彼此将不能检测到对方的

黑马程序员——java——线程间的通讯生产者与消费者

线程间的的通讯生产者与消费者 public class TestDemos3 { public static void main(String[] args) { Res r = new Res(); Input in = new Input(r); Output out = new Output(r); Thread t1 = new Thread(in); Thread t2 = new Thread(out); t1.start(); t2.start(); } } class Res