池州网站制作,网页首页怎么设计,wordpress 插件手机,佛山网站建设流程概述
实现我上一篇博客中提到的 实际上#xff0c;就是用synchronized代码块解决线程安全问题#xff0c;以及利用wait()、notify()实现线程阻塞、唤醒。
实现
pollV3() private Object lockBySynchronizednew Object();public int pollV3() {synchronized (lockBySynchr…概述
实现我上一篇博客中提到的 实际上就是用synchronized代码块解决线程安全问题以及利用wait()、notify()实现线程阻塞、唤醒。
实现
pollV3() private Object lockBySynchronizednew Object();public int pollV3() {synchronized (lockBySynchronized){ //synchronized代码块解决线程安全问题 while (tail 0) { // 没有元素try {lockBySynchronized.wait(); // 让出队元素的线程阻塞 直到被其他线程唤醒} catch (InterruptedException e) {log.info(等待队列有元素的过程中被打断,e);}}int polled arr[0]; // 队头元素log.info(出队成功队头元素为{},polled);System.arraycopy(arr,1,arr,0,tail-1);tail--; // 出队后 tail往前移动一位lockBySynchronized.notify();return polled;}}offerV3() public void offerV3(int value) {synchronized (lockBySynchronized){while (tail capacity) {try {lockBySynchronized.wait(); // 当前线程阻塞直到被唤醒或打断其他线程调用signal方法并且唤醒的线程刚好是该线程或其他线程调用signalAll方法 关联该condition的锁会被自动释放} catch (InterruptedException e) {log.info(被打断了...);}}arr[tail] value;log.info(元素 {}入队成功,value);tail;lockBySynchronized.notify(); // 唤醒要出队元素的线程 执行出队元素的逻辑}}测试用例 public static void main(String[] args) throws InterruptedException {ArrayQueue queue new ArrayQueue(3);Thread t1 new Thread(() - {queue.offerV3(1);queue.offerV3(2);}, t1);Thread t2 new Thread(() - {queue.offerV3(3);}, t2);Thread t3 new Thread(() - {queue.offerV3(4);}, t3);t1.start();t2.start();t3.start();//25ms以后执行一次出队操作 由于发生了出队操作 入队操作就应该可以成功log.info(5s以后执行一次出队操作);TimeUnit.SECONDS.sleep(5);int polled queue.pollV3();log.info(出队的元素{},polled);// t1 t2 t3 3个线程的代码都执行完后再遍历队列t1.join();t2.join();t3.join();queue.print();}测试用例输出 最后
这篇博客应该就是基于数组实现队列的最后一篇了吧。
好了如果对你有帮助的话欢迎点个免费的赞哦。
