线程协作-生产者/消费者问题

时间：2017-09-02 18:12:43 阅读：269 评论：0 收藏：0 [点我收藏+]

标签：clear span 消费者 util ext ima border color indent

处理线程协作时，在同步方法中，必须作进入检查，如果不满足进入条件，须放弃锁，进入等待

完成业务处理后，要做清场处理，同时完成唤醒其他等待的线程的操作

1. import java.util.ArrayList;

2. import java.util.List;

3. /** 定义一个盘子类，可以放鸡蛋和取鸡蛋 */

4. public class Plate {

5. /** 装鸡蛋的盘子 */

6. List<Object> eggs = new ArrayList<Object>();

7. /** 取鸡蛋 */

8. public synchronized Object getEgg() {

9. while (eggs.size() == 0) {

10. try {

11. wait();

12. } catch (InterruptedException e) {

13. e.printStackTrace();

14. }

15. }

16. Object egg = eggs.get(0);

17. eggs.clear();// 清空盘子

18. notify();// 唤醒阻塞队列的某线程到就绪队列

19. System.out.println("拿到鸡蛋");

20. return egg;

21. }

22. /** 放鸡蛋 */

23. public synchronized void putEgg(Object egg) {

24. while (eggs.size() > 0) {

25. try {

26. wait();

27. } catch (InterruptedException e) {

28. e.printStackTrace();

29. }

30. }

31. eggs.add(egg);// 往盘子里放鸡蛋

32. notify();// 唤醒阻塞队列的某线程到就绪队列

33. System.out.println("放入鸡蛋");

34. }

35. static class AddThread implements Runnable {

36. private Plate plate;

37. private Object egg = new Object();

38. public AddThread(Plate plate) {

39. this.plate = plate;

40. }

41. public void run() {

42. plate.putEgg(egg);

43. }

44. }

45. static class GetThread implements Runnable {

46. private Plate plate;

47. public GetThread(Plate plate) {

48. this.plate = plate;

49. }

50. public void run() {

51. plate.getEgg();

52. }

53. }

54. public static void main(String args[]) {

55. Plate plate = new Plate();

56. for(int i = 0; i < 10; i++) {

57. new Thread(new AddThread(plate)).start();

58. new Thread(new GetThread(plate)).start();

59. }

60. }

61. }