黑马程序员技术交流社区

标题: 关于多线程控制问 [打印本页]

---

作者: zjm10zj    时间: 2013-3-23 09:19
标题: 关于多线程控制问


怎么对多个线程同步通信进行控制！使用那些方法！

---

作者: 李万海    时间: 2013-3-23 10:44
在多线程并发执行的时候，可以使用wait()和notify（）方法在多个线程间通信。  前提是必须是同步方法之间进行通信，必须使用锁对象调动wait()和notify()
使用。通信的代码必须写在同步代码中，必须使用锁对象来调用wait()和notify()，wait()方法可以控制当前线程等待, 直到其他线程调用notify()或者notifyAll()方法才被唤醒。
给你一个生产者消费者的例子：
/**
* 公共资源类
*/  
public class PublicResource {  
    private int number = 0;  
  
    /**
     * 增加公共资源
     */  
    public synchronized void increace() {  
        while (number != 0) {  
            try {  
                wait();  
            } catch (InterruptedException e) {  
                e.printStackTrace();  
            }  
        }  
        number++;  
        System.out.println(number);  
        notify();  
    }  
  
    /**
     * 减少公共资源
     */  
    public synchronized void decreace() {  
        while (number == 0) {  
            try {  
                wait();  
            } catch (InterruptedException e) {  
                e.printStackTrace();  
            }  
        }  
        number--;  
        System.out.println(number);  
        notify();  
    }  
}  
/**
* 生产者线程，负责生产公共资源
*/  
public class ProducerThread implements Runnable {  
    private PublicResource resource;  
  
    public ProducerThread(PublicResource resource) {  
        this.resource = resource;  
    }  
   
    public void run() {  
        for (int i = 0; i < 10; i++) {  
            try {  
                Thread.sleep((long) (Math.random() * 1000));  
            } catch (InterruptedException e) {  
                e.printStackTrace();  
            }  
            resource.increace();  
        }  
    }  
}  
/**
* 消费者线程，负责消费公共资源
*/  
public class ConsumerThread implements Runnable {  
    private PublicResource resource;  
  
    public ConsumerThread(PublicResource resource) {  
        this.resource = resource;  
    }  
  
   
    public void run() {  
        for (int i = 0; i < 10; i++) {  
            try {  
                Thread.sleep((long) (Math.random() * 1000));  
            } catch (InterruptedException e) {  
                e.printStackTrace();  
            }  
            resource.decreace();  
        }  
    }  
}  
public class ProducerConsumerTest {  
    public static void main(String[] args) {  
        PublicResource resource = new PublicResource();  
        new Thread(new ProducerThread(resource)).start();  
        new Thread(new ConsumerThread(resource)).start();  
        new Thread(new ProducerThread(resource)).start();  
        new Thread(new ConsumerThread(resource)).start();  
        new Thread(new ProducerThread(resource)).start();  
        new Thread(new ConsumerThread(resource)).start();  
    }  
}

---

作者: lucy198921    时间: 2013-3-24 15:55
多线程的同步控制与线程间的通信：可以用synchronized、wait()和notifyAll()完成以下情景
模拟3个人排队买票，每人买一张票。售票员（TicketSeller类）只有1张5元的钱，电影票5元一张。
张某拿着1张20元的人民币排在第一，李某拿着1张10元的人民币排在第二，王某拿着1张5元的人民币排在第三。
（提示：定义一个售票员TicketSeller类，属性包括5元钱张数fiveNumber、10元钱张数tenNumber和20元钱张数twentyNumber，方法为同步方法卖票sellTicket(int receiveMoney), 创建三个线程张某Zhang、李某Li和王某Wang,这三个线程共享一个售票员类对象。）




class MyThread88 implements Runnable {
  int i=100;
  public synchronized void m1() throws InterruptedException {
    i=1000;
    Thread.sleep(5000);
    System.out.println("i"+"="+i);
  }
  public synchronized void m2() throws InterruptedException {
    Thread.sleep(2500);
      i=2000;
  }
  public void run() {
   try {
     m1();
   } catch (InterruptedException e) {
       e.printStackTrace();
     }
  }
}

public class TongBu {
  public static void main(String[] args) {
    MyThread88 k = new MyThread88();
    Thread t = new Thread(k);
    t.start();
    try {
      k.m2();
    } catch (InterruptedException e) {
        e.printStackTrace();
      }
    System.out.println(k.i);
  }
}

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2