黑马程序员技术交流社区

标题: 分享下-多线程实现数组的同步赋值和同步打印 [打印本页]
作者: 王自强    时间: 2012-8-29 16:02
标题: 分享下-多线程实现数组的同步赋值和同步打印
  1. import java.util.concurrent.locks.*;
  2. class BoundedBuffer
  3. {
  4. final Lock lock = new ReentrantLock();
  5. final Condition notFull = lock.newCondition();
  6. final Condition notEmpty = lock.newCondition();

  8. final Object[] items = new Object[100];
  9. int count,putptr,takeptr;

  11. public void put(Object x)throws InterruptedException
  12. {
  13. lock.lock();
  14. try
  15. {
  16. while(count==items.length)
  17. notFull.await();
  18. items[putptr] = x;
  19. System.out.println(Thread.currentThread().getName()+"在向数组中添加第"+putptr+"号角标的元素："+x);
  20. if(++putptr == items.length)
  21. putptr = 0;
  22. ++count;
  23. notEmpty.signal();
  24. }
  25. finally
  26. {
  27. lock.unlock();
  28. }
  29. }
  30. public Object take()throws InterruptedException
  31. {
  32. lock.lock();
  33. try
  34. {
  35. while(count==0)
  36. notEmpty.await();
  37. Object x = items[takeptr];
  38. System.out.println(Thread.currentThread().getName()+"在从数组中取出第"+takeptr+"号角标的元素："+x);
  39. if(++takeptr == items.length)
  40. takeptr = 0;
  41. --count;
  42. notFull.signal();
  43. return x;
  44. }
  45. finally
  46. {
  47. lock.unlock();
  48. }
  49. }
  50. }
  51. class Put implements Runnable
  52. {
  53. BoundedBuffer bb;
  54. int x = 20;
  55. Put(BoundedBuffer bb)
  56. {
  57. this.bb = bb;
  58. }
  59. public void run()//不能抛，只能在内部进行try
  60. {
  61. while(x-->0)
  62. {
  63. try
  64. {
  65. bb.put(x);
  66. }
  67. catch (InterruptedException e)
  68. {
  69. }
  70. }
  71. }
  72. }
  73. class Take implements Runnable
  74. {
  75. BoundedBuffer bb;
  76. int x = 20;
  77. Take(BoundedBuffer bb)
  78. {
  79. this.bb = bb;
  80. }
  81. public void run()//不能抛，只能在内部进行try
  82. {
  83. while(x-->0)
  84. {
  85. try
  86. {
  87. System.out.println(bb.take());
  88. }
  89. catch (InterruptedException e)
  90. {
  91. }
  92. }
  93. }
  94. }
  95. class demo
  96. {
  97. public static void main(String[] s)
  98. {
  99. BoundedBuffer bb = new BoundedBuffer();
  100. Put p = new Put(bb);
  101. Take t = new Take(bb);
  102. new Thread(p).start();
  103. new Thread(p).start();
  104. new Thread(p).start();
  105. new Thread(p).start();

  107. new Thread(t).start();
  108. new Thread(t).start();
  109. new Thread(t).start();
  110. }
  111. }
复制代码




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