「java线程通信几种方法」java线程间的通信
今天给各位分享java线程通信几种方法的知识,其中也会对java线程间的通信进行解释,如果能碰巧解决你现在面临的问题,别忘了关注本站,现在开始吧!
本文目录一览:
Java里如何实现线程间通信
当线程间是可以共享资源时,线程间通信是协调它们的重要的手段。Object类中wait()notify()notifyAll()方法可以用于线程间通信关于资源的锁的状态。
Java向线程传递数据的三种方法
在传统的同步开发模式下 当我们调用一个函数时 通过这个函数的参数将数据传入 并通过这个函数的返回值来返回最终的计算结果 但在多线程的异步开发模式下 数据的传递和返回和同步开发模式有很大的区别 由于线程的运行和结束是不可预料的 因此 在传递和返回数据时就无法象函数一样通过函数参数和return语句来返回数据 本文就以上原因介绍了几种用于向线程传递数据的方法 在下一篇文章中将介绍从线程中返回数据的方法
欲先取之 必先予之 一般在使用线程时都需要有一些初始化数据 然后线程利用这些数据进行加工处理 并返回结果 在这个过程中最先要做的就是向线程中传递数据
一 通过构造方法传递数据
在创建线程时 必须要建立一个Thread类的或其子类的实例 因此 我们不难想到在调用start方法之前通过线程类的构造方法将数据传入线程 并将传入的数据使用类变量保存起来 以便线程使用(其实就是在run方法中使用) 下面的代码演示了如何通过构造方法来传递数据
package mythread;
public class MyThread extends Thread
{
private String name;
public MyThread (String name)
{
this name = name;
}
public void run()
{
System out println( hello + name);
}
public static void main(String[] args)
{
Thread thread = new MyThread ( world );
thread start();
}
}
由于这种方法是在创建线程对象的同时传递数据的 因此 在线程运行之前这些数据就就已经到位了 这样就不会造成数据在线程运行后才传入的现象 如果要传递更复杂的数据 可以使用集合 类等数据结构 使用构造方法来传递数据虽然比较安全 但如果要传递的数据比较多时 就会造成很多不便 由于Java没有默认参数 要想实现类似默认参数的效果 就得使用重载 这样不但使构造方法本身过于复杂 又会使构造方法在数量上大增 因此 要想避免这种情况 就得通过类方法或类变量来传递数据
二 通过变量和方法传递数据
向对象中传入数据一般有两次机会 第一次机会是在建立对象时通过构造方法将数据传入 另外一次机会就是在类中定义一系列的public的方法或变量(也可称之为字段) 然后在建立完对象后 通过对象实例逐个赋值 下面的代码是对MyThread 类的改版 使用了一个setName方法来设置name变量
package mythread;
public class MyThread implements Runnable
{
private String name;
public void setName(String name)
{
this name = name;
}
public void run()
{
System out println( hello + name);
}
public static void main(String[] args)
{
MyThread myThread = new MyThread ();
myThread setName( world );
Thread thread = new Thread(myThread);
thread start();
}
}
三 通过回调函数传递数据
上面讨论的两种向线程中传递数据的方法是最常用的 但这两种方法都是main方法中主动将数据传入线程类的 这对于线程来说 是被动接收这些数据的 然而 在有些应用中需要在线程运行的过程中动态地获取数据 如在下面代码的run方法中产生了 个随机数 然后通过Work类的process方法求这三个随机数的和 并通过Data类的value将结果返回 从这个例子可以看出 在返回value之前 必须要得到三个随机数 也就是说 这个value是无法事先就传入线程类的
package mythread;
class Data
{
public int value = ;
}
class Work
{
public void process(Data data Integer numbers)
{
for (int n : numbers)
{
data value += n;
}
}
}
public class MyThread extends Thread
{
private Work work;
public MyThread (Work work)
{
this work = work;
}
public void run()
{
java util Random random = new java util Random();
Data data = new Data();
int n = random nextInt( );
int n = random nextInt( );
int n = random nextInt( );
work process(data n n n ); // 使用回调函数
System out println(String valueOf(n ) + + + String valueOf(n ) + +
+ String valueOf(n ) + = + data value);
}
public static void main(String[] args)
{
Thread thread = new MyThread (new Work());
thread start();
}
}
lishixinzhi/Article/program/Java/hx/201311/26623
线程间通信有哪些方式
线程间通信方式有:
1、volatile
volatile有两大特性,一是可见性,二是有序性,禁止指令重排序,其中可见性就是可以让线程之间进行通信。volatile语义保证线程可见性有两个原则保证:
(1)所有volatile修饰的变量一旦被某个线程更改,必须立即刷新到主内存。
(2)所有volatile修饰的变量在使用之前必须重新读取主内存的值。
2、等待/通知机制
等待通知机制是基于wait和notify方法来实现的,在一个线程内调用该线程锁对象的wait方法,线程将进入等待队列进行等待直到被通知或者被唤醒。
3、join方式
join其实合理理解成是线程合并,当在一个线程调用另一个线程的join方法时,当前线程阻塞等待被调用join方法的线程执行完毕才能继续执行,所以join的好处能够保证线程的执行顺序。
但是如果调用线程的join方法其实已经失去了并行的意义,虽然存在多个线程,但是本质上还是串行的,最后join的实现其实是基于等待通知机制的。
4、threadLocal
threadLocal方式的线程通信,不像以上三种方式是多个线程之间的通信,它更像是一个线程内部的通信,将当前线程和一个map绑定,在当前线程内可以任意存取数据,减省了方法调用间参数的传递。
线程特点:
1、轻型实体
线程中的实体基本上不拥有系统资源,只是有一点必不可少的、能保证独立运行的资源。线程的实体包括程序、数据和TCB。线程是动态概念,它的动态特性由线程控制块TCB(Thread Control Block)描述。
2、独立调度和分派的基本单位
在多线程OS中,线程是能独立运行的基本单位,因而也是独立调度和分派的基本单位。由于线程很“轻”,故线程的切换非常迅速且开销小(在同一进程中的)。
3、可并发执行
在一个进程中的多个线程之间,可以并发执行,甚至允许在一个进程中所有线程都能并发执行;同样,不同进程中的线程也能并发执行,充分利用和发挥了处理机与外围设备并行工作的能力。
4、共享进程资源
在同一进程中的各个线程,都可以共享该进程所拥有的资源,这首先表现在:所有线程都具有相同的地址空间(进程的地址空间),这意味着,线程可以访问该地址空间的每一个虚地址。
此外,还可以访问进程所拥有的已打开文件、定时器、信号量机构等。由于同一个进程内的线程共享内存和文件,所以线程之间互相通信不必调用内核。
JAVA线程间通信的几种方式
Java多线程间的通信
Java还提供了一种线程间通信的机制,这种通信通什么实现?
wait,notify等机制
或使用pipeInputStream和pipeOutputStream
1. 线程的几种状态
线程有四种状态,任何一个线程肯定处于这四种状态中的一种:
1) 产生(New):线程对象已经产生,但尚未被启动,所以无法执行。如通过new产生了一个线程对象后没对它调用start()函数之前。
2) 可执行(Runnable):每个支持多线程的系统都有一个排程器,排程器会从线程池中选择一个线程并启动它。当一个线程处于可执行状态时,表示它可能正处于线程池中等待排排程器启动它;也可能它已正在执行。如执行了一个线程对象的start()方法后,线程就处于可执行状态,但显而易见的是此时线程不一定正在执行中。
3) 死亡(Dead):当一个线程正常结束,它便处于死亡状态。如一个线程的run()函数执行完毕后线程就进入死亡状态。
4) 停滞(Blocked):当一个线程处于停滞状态时,系统排程器就会忽略它,不对它进行排程。
请问线程间通信的几种方法
线程间通信的方法如下:
1、全局变量
进程中的线程间内存共享,这是比较常用的通信方式和交互方式。定义全局变量时最好使用volatile来定义,以防编译器对此变量进行优化。
2、Message消息机制
常用的Message通信的接口主要有两个:PostMessage和PostThreadMessage,PostMessage为线程向主窗口发送消息。而PostThreadMessage是任意两个线程之间的通信接口。
3、CEvent对象
CEvent为MFC中的一个对象,可以通过对CEvent的触发状态进行改变,从而实现线程间的通信和同步。
更多关于线程间通信的几种方法,进入:查看更多内容
JAVA如何多线程通信
在通信方面,建议阅读Mina的源码,会有很大帮助,
源码对并发有处理。
说一点自己的浅薄经验,高并发下,接受数据是来不急处理的,会导致阻塞。
建议用专门的线程接收数据。不负责处理,放在队列里面。
然后有专门的线程去处理,把接收和处理分开。这是基本原则。
如果处理数据过程太慢而队列里堆积过多,就需要监测队列大小,如果过大,就启动多个线程。至于启动多少线程,可以写算法优化。记得空闲时关闭。
关于java线程通信几种方法和java线程间的通信的介绍到此就结束了,不知道你从中找到你需要的信息了吗 ?如果你还想了解更多这方面的信息,记得收藏关注本站。