黑马程序员技术交流社区

标题: 安全线程：lock的运用 [打印本页]

---

作者: xiexie758    时间: 2015-10-31 18:02
标题: 安全线程：lock的运用
题目：开启两个线程，每个线程相隔往数组装数据，数组长度为6：

package itcast;

import java.util.Random;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class Demo20 {

        public static void main(String[] args) {
                // TODO 自动生成的方法存根
                int [] arr=new int[6];
                ArrayAdd array=new ArrayAdd(arr);
                new Thread(array).start();
                new Thread(array).start();
        }

}
class ArrayAdd implements Runnable
{
        private int[] in;
        private int num=0;
        private Random ra=new Random();
        private ReentrantLock lock=new ReentrantLock();
                Condition con=        lock.newCondition();
        /**
         * @param in
         */
        public ArrayAdd(int[] in) {
                super();
                this.in = in;
        }
        public void run(){
               
                while(num<in.length){//判断添加的数组数量是否小于数组长度
                               
                                lock.lock();//线程拿到锁
                                con.signal();//线程进来后，唤醒其他线程
                                if(num<in.length){
                                       
                                        try {
                                                Thread.sleep(300);
                                        } catch (InterruptedException e) {
                                               
                                                e.printStackTrace();
                                        }
                                        finally{
                                                int a=(ra.nextInt(20)+1);//随机生成的数
                                                in[num]=a;
                                                System.out.println(Thread.currentThread().getName()+":"+a);
                                                num++;
                                                try {
                                                        con.await();//调用await，放弃执行权
                                                } catch (InterruptedException e) {
                                                        // TODO 自动生成的 catch 块
                                                        e.printStackTrace();
                                                }
                                                //lock.unlock();//想了想，这个锁就不用释放了，await已经释放执行权并释放了锁
                                               
                                       
                                        }
                                       
                       
                                }
               
       
                }
        }
       
}

---

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

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