Java读写锁,代码编译测试 - 在线编译器(yxjc123.com)

结果显示HTML 点击运行
import java.util.ArrayList;
import java.util.Date;
import java.util.concurrent.locks.ReentrantReadWriteLock;

public class HelloWorld{
    public static long getTimeStamp(){
        Date date = new Date();
        long timestamp = date.getTime();//返回13位时间戳
        return timestamp;
    }

    public static void main(String[] args) throws InterruptedException {
        RWArrayList rwArrayList = new RWArrayList();
        Thread t1 = new Thread(new Runnable() {
            @Override
            public void run() {
                //添加100个数
                for (int i=0; i<10; i++) {
                    rwArrayList.add(i);
                }
                System.out.println("添加数据完成");
            }
        });
        Thread t2 = new Thread(new Runnable() {
            @Override
            public void run() {
                //读
                long time1 = getTimeStamp();
                for (int i=0; i<rwArrayList.size(); i++) {
                    rwArrayList.get(i);
                }
                long time2 = getTimeStamp();
                System.out.println("线程2 " + Thread.currentThread().getName() + "，时间差值 "+(time2-time1));
            }
        });
        Thread t3 = new Thread(new Runnable() {
            @Override
            public void run() {
                //读
                long time1 = getTimeStamp();
                for (int i=0; i<rwArrayList.size(); i++) {
                    rwArrayList.get(i);
                }
                long time2 = getTimeStamp();
                System.out.println("线程3 " + Thread.currentThread().getName() + "，时间差值 "+(time2-time1));
            }
        });
//        Thread t4 = new Thread(new Runnable() {
//            @Override
//            public void run() {
//                //写
//                long time1 = getTimeStamp();
//                for (int i=0;i<5;i++) {
//                    rwArrayList.removeLast();
//                }
//                long time2 = getTimeStamp();
//                System.out.println("线程4 " + Thread.currentThread().getName() + "，时间差值 "+(time2-time1));
//            }
//        });
        //开启3个线程
        System.out.println("读写锁");
        t1.start();
        t2.start();
        t3.start();
        t1.join();
//        t4.start();

    }
}

class RWArrayList<E> {
    private ArrayList<E> list = new ArrayList<E>();
    ReentrantReadWriteLock lock = new ReentrantReadWriteLock();
    ReentrantReadWriteLock.ReadLock readLock = lock.readLock();
    ReentrantReadWriteLock.WriteLock writeLock = lock.writeLock();



    public void add(E element) {
        try {
            writeLock.lock();
            list.add(element);
        } finally {
            writeLock.unlock();
        }
    }

    public void removeLast() {
        try {
            writeLock.lock();
            if(list.size()!=0){
                list.remove(list.size() - 1);
            }
        } finally {
            writeLock.unlock();
        }

    }

    public void set(int index, E element) {
        try {
            writeLock.lock();
            list.set(index, element);
        } finally {
            writeLock.unlock();
        }

    }

    public int size() {
        try {
            // 读锁
            readLock.lock();
            return list.size();
        } finally {
            readLock.unlock();
        }
    }

    public E get(int index) {
        try {
            // 读锁
            readLock.lock();
            try {
                Thread.sleep(100);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
            return list.get(index);
        } finally {
            readLock.unlock();
        }
    }

}
​x
 
import java.util.ArrayList;
import java.util.Date;
import java.util.concurrent.locks.ReentrantReadWriteLock;
​
public class HelloWorld{
    public static long getTimeStamp(){
        Date date = new Date();
        long timestamp = date.getTime();//返回13位时间戳
        return timestamp;
    }
​
    public static void main(String[] args) throws InterruptedException {
        RWArrayList rwArrayList = new RWArrayList();
        Thread t1 = new Thread(new Runnable() {
            @Override
            public void run() {
                //添加100个数
                for (int i=0; i<10; i++) {
                    rwArrayList.add(i);
                }
                System.out.println("添加数据完成");
            }
Java读写锁在线测试，这是一个简单方便的Java在线运行工具，支持在线编译、在线调试和在线结果的实时反馈。