Shulou(Shulou.com)06/02 Report--

小编给大家分享一下Java多线程中读写锁分离设计模式怎么用，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧!

主要完成任务：

1.read read 并行化

2.read write 不允许

3.write write 不允许

public class ReaderWorker extends Thread { private final SharedData data; public ReaderWorker(SharedData data) { this.data = data; } @Override public void run() { while (true) { try { char[] readBuf = data.read(); System.out.println(Thread.currentThread().getName() + " reads " + String.valueOf(readBuf)); } catch (InterruptedException e) { e.printStackTrace(); } } }}public class ReadWriteLock { /** * 当前有几个线程 在对它进行读操作 */ private int readingReaders = 0; /** * 当前有几个线程 等待读操作 */ private int waitingReaders = 0; /** * 当前有几个线程 正在写操作 */ private int writingWriters = 0; /** * 当前有几个线程 正在写操作 */ private int waitingWriters = 0; /** * 偏向于写 */ private boolean preferWriter = true; public ReadWriteLock() { this(true); } public ReadWriteLock(boolean preferWriter) { this.preferWriter = preferWriter; } public synchronized void readLock() throws InterruptedException { this.waitingReaders++; try { /** * 让写的线程先运行 */ while (writingWriters > 0||(preferWriter&&waitingWriters>0)) { this.wait(); } this.readingReaders++; } finally { this.waitingReaders--; } } public synchronized void readUnLock() { this.readingReaders--; this.notifyAll(); } public synchronized void writeLock() throws InterruptedException { this.waitingWriters++; try { while (readingReaders > 0 || writingWriters > 0) { this.wait(); } this.writingWriters++; } finally { this.waitingWriters--; } } public synchronized void writeUnlock() { this.writingWriters--; this.notifyAll(); }}public class SharedData { private final char[] buffer; private final ReadWriteLock lock = new ReadWriteLock(); public SharedData(int size) { this.buffer = new char[size]; for (int i = 0; i

< size; i++) { this.buffer[i] = '*'; } } public char[] read() throws InterruptedException { try { lock.readLock(); return this.doRead(); } finally { lock.readUnLock(); } } public void write(char c) throws InterruptedException { try { lock.writeLock(); this.doWrite(c); } finally { lock.writeUnlock(); } } private void doWrite(char c) { for (int i = 0; i < buffer.length; i++) { buffer[i] = c; slowly(10); } } private char[] doRead() { char[] newBuf = new char[buffer.length]; for (int i = 0; i < buffer.length; i++) { newBuf[i] = buffer[i]; } slowly(50); return newBuf; } private void slowly(int millisecond) { try { Thread.sleep(millisecond); } catch (InterruptedException e) { e.printStackTrace(); } }}public class WriterWorker extends Thread { private static final Random random = new Random(System.currentTimeMillis()); private final SharedData data; private final String filter; private int index = 0; public WriterWorker(SharedData data, String filter) { this.data = data; this.filter = filter; } @Override public void run() { try { while (true) { char c = nextChar(); data.write(c); Thread.sleep(random.nextInt(1000)); } } catch (InterruptedException e) { e.printStackTrace(); } } private char nextChar() { char c = filter.charAt(index); index++; if (index >

= filter.length()) index = 0; return c; }}/** * * ReadWriteLock */public class ReadWriteLockClient { public static void main(String[] args) { final SharedData sharedData = new SharedData(10); new ReaderWorker(sharedData).start(); new ReaderWorker(sharedData).start(); new ReaderWorker(sharedData).start(); new ReaderWorker(sharedData).start(); new ReaderWorker(sharedData).start(); new WriterWorker(sharedData,"123456").start(); new WriterWorker(sharedData,"abcdef").start(); }}

Results:

Thread-0 reads **********

Thread-1 reads **********

Thread-2 reads **********

Thread-3 reads **********

Thread-1 reads aaaaaaaaaa

Thread-3 reads aaaaaaaaaa

Thread-0 reads aaaaaaaaaa

Thread-2 reads aaaaaaaaaa

Thread-1 reads aaaaaaaaaa

Thread-2 reads aaaaaaaaaa

Thread-0 reads aaaaaaaaaa

Thread-3 reads aaaaaaaaaa

Thread-1 reads aaaaaaaaaa

Thread-3 reads aaaaaaaaaa

Thread-0 reads aaaaaaaaaa

Thread-2 reads aaaaaaaaaa

Thread-2 reads aaaaaaaaaa

Thread-0 reads aaaaaaaaaa

Thread-1 reads aaaaaaaaaa

Thread-3 reads aaaaaaaaaa

Thread-2 reads aaaaaaaaaa

Thread-0 reads aaaaaaaaaa

Thread-1 reads aaaaaaaaaa

Thread-3 reads aaaaaaaaaa

Thread-0 reads bbbbbbbbbb

Thread-1 reads bbbbbbbbbb

Thread-2 reads bbbbbbbbbb

Thread-3 reads bbbbbbbbbb

Thread-0 reads bbbbbbbbbb

Thread-1 reads bbbbbbbbbb

Thread-3 reads bbbbbbbbbb

Thread-2 reads bbbbbbbbbb

Thread-0 reads bbbbbbbbbb

Thread-1 reads bbbbbbbbbb

Thread-2 reads bbbbbbbbbb

Thread-3 reads bbbbbbbbbb

Thread-0 reads bbbbbbbbbb

Thread-1 reads bbbbbbbbbb

Thread-3 reads bbbbbbbbbb

Thread-2 reads bbbbbbbbbb

Thread-1 reads 3333333333

Thread-2 reads 3333333333

Thread-3 reads 3333333333

...... omitted

The above is "Java multithreading read-write lock separation design pattern how to use" all the content of this article, thank you for reading! I believe that everyone has a certain understanding, hope to share the content to help everyone, if you still want to learn more knowledge, welcome to pay attention to the industry information channel!

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.