android_zhang
- 浏览: 538774 次
- 性别:
- 来自: 北京
-
文章分类
最新评论
-
tangyunliang：
大哥你太历害了谢谢
Android基于XMPP Smack Openfire开发IM【四】初步实现两个客户端通信 -
u013015029：
LZ,请问下，在// 添加消息到聊天窗口 ， 这里获取Ed ...
Android基于XMPP Smack Openfire开发IM【四】初步实现两个客户端通信 -
endual：
怎么保持会话，我搞不懂啊
Android基于XMPP Smack Openfire开发IM【一】登录openfire服务器 -
donala_zq：
显示：[2013-11-30 11:50:36 - Andro ...
android-----------新浪微博 -
donala_zq：
哥，运行不了啊
android-----------新浪微博
线程间通讯，当有多个生产者、消费者时，容易导致的问题。
一、当只有两个线程，一个生产、一个消费的时候，数据是没有问题的，如下：
运行效果：
二、当有两个生产者、消费者时，数据出现了问题：
运行效果（第五行、第六行都为生产者）：
三、如果为多个生产者和消费者，修改如下： if判断改为while判断，当线程被唤醒的时候，都要去判断一下flag; 并把notify 改为notifyAll唤醒线程，不管生产者还是消费者都唤醒。
运行效果：
一、当只有两个线程，一个生产、一个消费的时候，数据是没有问题的，如下：
package com.zzl.thread;
class MyResource{
private String name;
private int number = 1;
private boolean flag = false;
public synchronized void set(String name){
if(flag){
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
this.name = name +"......"+ number++;
System.out.println(Thread.currentThread().getName()+"...生产者..."+this.name);
this.flag = true;
this.notify();
}
public synchronized void print(){
if(!flag){
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println(Thread.currentThread().getName()+"---------消费者---------"+this.name);
this.flag = false;
this.notify();
}
}
class Producer implements Runnable{
private MyResource r;
public Producer(MyResource r){
this.r = r;
}
@Override
public void run() {
while(true){
r.set("苹果");
}
}
}
class Consumer implements Runnable{
private MyResource r;
public Consumer(MyResource r){
this.r = r;
}
@Override
public void run() {
while(true){
r.print();
}
}
}
public class ProducerConsumerDemo {
public static void main(String[] args) {
MyResource r = new MyResource();
Producer p = new Producer(r);
Consumer c = new Consumer(r);
Thread t1 = new Thread(p);
Thread t2 = new Thread(c);
t1.start();
t2.start();
}
}
运行效果：
Thread-1---------消费者---------苹果......40535 Thread-0...生产者...苹果......40536 Thread-1---------消费者---------苹果......40536 Thread-0...生产者...苹果......40537 Thread-1---------消费者---------苹果......40537 Thread-0...生产者...苹果......40538 Thread-1---------消费者---------苹果......40538 Thread-0...生产者...苹果......40539 Thread-1---------消费者---------苹果......40539 Thread-0...生产者...苹果......40540 Thread-1---------消费者---------苹果......40540 Thread-0...生产者...苹果......40541 Thread-1---------消费者---------苹果......40541 Thread-0...生产者...苹果......40542 Thread-1---------消费者---------苹果......40542 Thread-0...生产者...苹果......40543 Thread-1---------消费者---------苹果......40543 Thread-0...生产者...苹果......40544 Thread-1---------消费者---------苹果......40544
二、当有两个生产者、消费者时，数据出现了问题：
package com.zzl.thread;
class MyResource{
private String name;
private int number = 1;
private boolean flag = false;
public synchronized void set(String name){
if(flag){
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
this.name = name +"......"+ number++;
System.out.println(Thread.currentThread().getName()+"...生产者..."+this.name);
this.flag = true;
this.notify();
}
public synchronized void print(){
if(!flag){
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println(Thread.currentThread().getName()+"---------消费者---------"+this.name);
this.flag = false;
this.notify();
}
}
class Producer implements Runnable{
private MyResource r;
public Producer(MyResource r){
this.r = r;
}
@Override
public void run() {
while(true){
r.set("苹果");
}
}
}
class Consumer implements Runnable{
private MyResource r;
public Consumer(MyResource r){
this.r = r;
}
@Override
public void run() {
while(true){
r.print();
}
}
}
public class ProducerConsumerDemo {
public static void main(String[] args) {
MyResource r = new MyResource();
Producer p = new Producer(r);
Consumer c = new Consumer(r);
Thread t1 = new Thread(p);
Thread t2 = new Thread(p);
Thread t3 = new Thread(c);
Thread t4 = new Thread(c);
t1.start();
t2.start();
t3.start();
t4.start();
}
}
运行效果（第五行、第六行都为生产者）：
Thread-0...生产者...苹果......19803 Thread-2---------消费者---------苹果......19803 Thread-0...生产者...苹果......19804 Thread-2---------消费者---------苹果......19804 Thread-0...生产者...苹果......19805 Thread-1...生产者...苹果......19806 Thread-3---------消费者---------苹果......19806 Thread-1...生产者...苹果......19807 Thread-3---------消费者---------苹果......19807 Thread-1...生产者...苹果......19808 Thread-3---------消费者---------苹果......19808 Thread-1...生产者...苹果......19809 Thread-3---------消费者---------苹果......19809
三、如果为多个生产者和消费者，修改如下： if判断改为while判断，当线程被唤醒的时候，都要去判断一下flag; 并把notify 改为notifyAll唤醒线程，不管生产者还是消费者都唤醒。
package com.zzl.thread;
class MyResource{
private String name;
private int number = 1;
private boolean flag = false;
public synchronized void set(String name){
while(flag){
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
this.name = name +"......"+ number++;
System.out.println(Thread.currentThread().getName()+"...生产者..."+this.name);
this.flag = true;
this.notifyAll();
}
public synchronized void print(){
while(!flag){
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println(Thread.currentThread().getName()+"---------消费者---------"+this.name);
this.flag = false;
this.notifyAll();
}
}
class Producer implements Runnable{
private MyResource r;
public Producer(MyResource r){
this.r = r;
}
@Override
public void run() {
while(true){
r.set("苹果");
}
}
}
class Consumer implements Runnable{
private MyResource r;
public Consumer(MyResource r){
this.r = r;
}
@Override
public void run() {
while(true){
r.print();
}
}
}
public class ProducerConsumerDemo {
public static void main(String[] args) {
MyResource r = new MyResource();
Producer p = new Producer(r);
Consumer c = new Consumer(r);
Thread t1 = new Thread(p);
Thread t2 = new Thread(p);
Thread t3 = new Thread(c);
Thread t4 = new Thread(c);
t1.start();
t2.start();
t3.start();
t4.start();
}
}
运行效果：
Thread-0...生产者...苹果......20549 Thread-2---------消费者---------苹果......20549 Thread-1...生产者...苹果......20550 Thread-3---------消费者---------苹果......20550 Thread-0...生产者...苹果......20551 Thread-2---------消费者---------苹果......20551 Thread-1...生产者...苹果......20552 Thread-3---------消费者---------苹果......20552 Thread-0...生产者...苹果......20553 Thread-2---------消费者---------苹果......20553 Thread-1...生产者...苹果......20554 Thread-3---------消费者---------苹果......20554
分享到：
发表评论
-
Eclipse 注释模板设置
2013-06-07 17:57 0设置注释模板的入口： Window-<Preferen ... -
网络编程【十】URL
2013-03-21 10:12 861package com.zzl.http; import ... -
网络编程【九】Tcp 图片的上传
2013-03-21 09:32 795图片的上传服务器操作练习。 客户端把d:\pic\welcom ... -
网络编程【八】Tcp学习---文件的复制
2013-03-21 09:32 919Tcp小练习：文件的传输 ... -
网络编程【七】Tcp学习--文本装换服务器
2013-03-21 09:31 792Tcp练习小Demo 客户端代 ... -
网络编程【六】Tcp服务端与客户端互相通信
2013-03-20 09:41 1056客户端代码： package com.zzl.tcp; ... -
网络编程【五】Tcp简单玩下
2013-03-20 09:12 814[img] [/img] 第一、创建客户端 package ... -
网络编程【四】UDP聊天
2013-03-20 08:21 917菜鸟练习UDP 运行效果图： [img] [/img] ... -
网络编程【三】UDP键盘方式录入数据
2013-03-20 08:20 1039本课是在网络编程【二 ... -
网络编程【二】UDP通信发送端+接收端
2013-03-20 08:20 1572[img] [/img] [img] [/img] ... -
网络编程【一】
2013-03-19 11:01 841[img] [/img] [img] [/img] ... -
线程学习【九】线程的优先级、yield
2013-03-19 08:48 757调用线程的 toString 方法打印如下： 左边为线程名； ... -
线程学习【八】 join方法
2013-03-19 08:48 786多线程学习------join方法 package com ... -
线程学习【七】守护线程
2013-03-19 08:48 827菜鸟学习线程----------守护线程 package ... -
线程间通讯学习【六】
2013-03-19 08:47 714package com.zzl.thread; impo ... -
线程间通讯学习【四】
2013-03-18 13:53 715线程通讯的优化： package com.zzl.thread ... -
线程间通讯学习【三】
2013-03-18 13:20 733如果存一个资源，然后打印一个资源，需要的结果类似如下： mik ... -
线程间通讯学习【二】
2013-03-18 13:18 744解决线程间通信的安全问题：同步锁的使用： package ... -
线程间通讯学习【一】
2013-03-18 09:57 726package com.zzl.thread; /** ... -
Thread学习：死锁
2013-03-15 11:03 898package com.zzl.thread; /** ...
相关推荐
在"JAVA100例之实例64 JAVA线程间通讯"这个主题中，我们将深入探讨Java中实现线程间通信的几种主要方法。 1. **共享数据**：最直观的线程间通信方式是通过共享内存空间，即共享变量。只要对共享变量的操作是线程...
学习这部分内容可以帮助开发者深入理解多线程编程，特别是如何在不违反线程安全规则的情况下进行界面与后台的通信。 总结来说，"界面线程工作线程之间的通讯"是一个关键的编程主题，涉及多线程同步、消息队列和线程...
通过分析和学习这个代码，你可以更深入地理解如何在Visual C++中利用自定义消息进行线程间通信。 要注意的是，线程间通信还涉及同步问题，比如使用`Mutex`、`Semaphore`或`Event`等同步对象来避免数据竞争和死锁。...
在“Qt多线程通讯”DEMO中，主线程可能创建了一个`QThread`实例，并启动它。接着，一个工作对象（可能是自定义的QObject派生类）被移动到子线程中。这个工作对象可能会有一个接收参数的槽函数，用于处理主线程传递...
总结，这个"Android AIDL线程间通讯样例项目"是学习和理解Android进程间通信机制的一个宝贵资源。通过分析和实践项目中的`Apdu_Client_Test`和`Apdu_Main_Test`，开发者可以深入掌握AIDL的工作方式，以及如何在实际...
在IT领域，多线程是程序设计中的一个重要概念，特别是在并发执行和性能优化时。当一个应用程序需要...通过阅读“多线程之间通讯.docx”文档和观看“第五节(join()用法).mp4”视频，可以更深入地学习这些概念和技巧。
- 从提供的"多线程串口通讯实例"源码中，我们可以看到如何结合上述知识点，实现一个同时读取Excel数据和进行串口通信的程序。 - 源码可能包括一个主线程负责用户界面交互，一个或多个子线程用于串口通信，确保数据...
synchronized关键字提供了基本的线程同步，而wait-notify机制和Lock接口则提供了更高级的线程通讯和控制手段。在实际开发中，根据具体需求选择合适的同步策略，可以提高程序的效率和正确性。通过学习和实践...
在实际应用中，我们还需要考虑线程同步问题，比如使用互斥锁（mutex）防止多个线程同时访问共享资源，使用条件变量（condition variable）来协调线程间的等待和唤醒等。此外，为了保证程序的健壮性，异常处理和错误...
通过分析这些源码，我们可以学习到如何在实际项目中应用事件对象进行线程间的通信。 总之，多线程事件对象通讯是Windows编程中的重要概念，通过理解和掌握这一技术，开发者可以编写出更加高效和可靠的多线程程序。...
通过学习和实践这些C#多线程示例，开发者能够更好地掌握如何在应用程序中有效地使用多线程，提高程序的性能和用户体验。在实际项目中，应根据任务特性和系统需求选择合适的线程管理策略，确保程序的稳定性和效率。
Disruptor是一款由LMAX交易所开发的开源Java框架，它专为高并发环境下的线程间通信设计，致力于提供极低的延迟和高效的性能。在Java开发中，尤其是在需要处理大量并发请求的系统中，Disruptor是一个重要的工具，它...
自己闲暇时候写的socket多线程通讯模型，代码虽然比较简单，但是比较容易扩展，麻雀虽小，五脏俱全。
但是有参考价值.zip上位机开发VC串口学习资料源码下载[233]多线程串口通讯例子,vc#开发的例子。代码比较简洁。但是有参考价值.zip上位机开发VC串口学习资料源码下载[233]多线程串口通讯例子,vc#开发的例子。代码比较...
以上知识点涵盖了C#中多线程串口通讯的基本原理和实践技巧，通过学习和掌握这些内容，开发者可以编写出高效、稳定的串口通信程序。在实际项目中，还需要根据具体需求和硬件环境调整和完善代码。
本文将深入探讨"异步和多线程socket通讯"这一主题，基于提供的描述和标签，我们将讨论如何利用多线程和异步机制来提升socket通信的效率和响应性。 首先，Socket是一种在应用程序与网络服务之间建立连接的接口，它...
而"多线程串口通讯实例_622"可能是一个源码文件，包含了完整的VC++项目代码，供开发者参考和学习。 总结来说，这个实例为开发者提供了一个实践多线程串口通信的范例，通过VC++编程语言，展示了如何在多个串口通信中...
通过阅读和理解这部分代码，我们可以深入学习如何在易语言中实现高效的线程间通信。 总的来说，易语言线程通信涉及到了线程的创建、消息的发送与接收等关键操作。理解和掌握这些知识点，能够帮助开发者编写出更加...
本资源提供的"多线程UDP通讯程序源代码"就是一个很好的实践案例，它涉及到计算机网络中的用户数据报协议（UDP）和多线程编程技术。以下是关于这两个关键知识点的详细解释： 1. **用户数据报协议（UDP）**： UDP是...
"多线程编程之三——线程间通讯"是多线程编程中的一大重点。线程间通讯是为了实现不同线程之间的协作，通常包括共享数据、信号量、事件、消息队列等机制。这部分将详细解释这些通信方式的使用和注意事项，比如如何...