多线程之wait与notify实现线程间通信
一个线程执行相加的操作，相加结束后，通知另一个线程打印。
?
?
/* * To change this template, choose Tools | Templates * and open the template in the editor. */package com.xiva.baseKnowledge;import java.util.concurrent.TimeUnit;import java.util.logging.Level;import java.util.logging.Logger;/** * * @author Administrator */public class MutiThread { public static int count = 0; //public static boolean mutex = true; public synchronized void print() { System.out.println(count); } public synchronized void add(int i) { count = count + i; System.out.println("add"); } public static void main(String[] args) { MutiThread mThread = new MutiThread(); PrintThread pThread = new PrintThread(mThread); AddThread addThread = new AddThread(pThread); addThread.start(); pThread.start(); }}class PrintThread extends Thread { private final MutiThread mThread; private volatile boolean startP = false; public PrintThread(MutiThread mThread) { this.mThread = mThread; } public MutiThread getMThread(){ return this.mThread; } public synchronized void notifyPrint(){ startP = true; notify(); } public synchronized void print(){ if(startP){ mThread.print(); startP = false; } else{ try { wait(); } catch (InterruptedException ex) { Logger.getLogger(AddThread.class.getName()).log(Level.SEVERE, null, ex); } } } @Override public void run() { while (true) { print(); } }}class AddThread extends Thread { private final PrintThread pThread; public AddThread(PrintThread pThread) { this.pThread = pThread; } @Override public void run() { for (int i = 1; i < 1000; i++) { try { //Thread.sleep(5000); TimeUnit.SECONDS.sleep(5); } catch (InterruptedException ex) { Logger.getLogger(MutiThread.class.getName()).log(Level.SEVERE, null, ex); } pThread.getMThread().add(i); pThread.notifyPrint(); } }}?
调用notifyPrint方法通知另一个线程启动打印。