线程之间的通信，可通过对对象的成员变量的状态修改，达到控制线程的目的。
Java中，线程要基于对象才能创建。如：
ThreadTest t1 = new ThreadTest();
t1.start();//启动一个线程，并运行ThreadTest 中的run()方法
如何对另外一个线程的状态控制，通过传入另外那个对象的实例，然后调用另外这个对象的私有函数，该私有函数内改变成员变量的状态。
为什么是私有函数，是为了达到更好的封装的目的。
程序如下：
package Multithread;
//import java.util.concurrent.*;
class ThreadObject1 implements Runnable {
private ThreadObject2 threadObject2 ;
public ThreadObject1(ThreadObject2 threadObject2) { //传入另外一个对象ThreadObject2
this.threadObject2 = threadObject2 ;
}
public void run() {
try {
//TimeUnit.SECONDS.sleep(3);
System.out.println(“i’m going.”);
threadObject2.SendMessage(); //修改另外对象ThreadObject2的成员变量，从而改变基于threadObject2对象的线程的运行状态
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
class ThreadObject2 implements Runnable {
private volatile boolean go = false;
public void SendMessage() throws InterruptedException { //修改成员变量状态
go = true;
}
public void waiting() { //忙等待，遇到go的状态变为true则跳出循环。
while (go == false)
;
System.out.println(“He has gone.”);
}
public void run() {
waiting();
}
}
public class BusyWaiting {
public static void main(String[] args) {
ThreadObject2 threadObject2 = new ThreadObject2();
ThreadObject1 threadObject1 = new ThreadObject1(threadObject2);
new Thread(threadObject1).start();
new Thread(threadObject2).start();
}
}
程序运行结果：
i’m going.
He has gone.
以上其实总共有三个线程，一个主线程，两个子线程。对于希望简化只需要通过主线程控制子线程中断的话，可以通过如下代码实现。
class Example2 extends Thread {
volatile boolean stop = false;// 线程中断信号量
public static void main(String args[]) throws Exception {
Example2 thread = new Example2();
System.out.println(“Starting thread…”);
thread.start();
Thread.sleep(3000);
System.out.println(“Asking thread to stop…”);
// 设置中断信号量
thread.stop = true;
Thread.sleep(3000);
System.out.println(“Stopping application…”);
}
public void run() {
// 每隔一秒检测一下中断信号量
while (!stop) {
System.out.println(“Thread is running…”);
long time = System.currentTimeMillis();
/*
* 使用while循环模拟 sleep 方法，这里不要使用sleep，否则在阻塞时会 抛
* InterruptedException异常而退出循环，这样while检测stop条件就不会执行，
* 失去了意义。
*/
while ((System.currentTimeMillis() – time < 1000)) {}
}
System.out.println(“Thread exiting under request…”);
}
}