两个线程按顺序打印1~100的几种实现
两个线程按顺序打印1~100的几种实现方法
1.atomicIntegerImpl
2.volatileLockImpl
3.reentrantLockImpl
4.synchronizedImpl
import java.util.concurrent.atomic.AtomicInteger;import java.util.concurrent.locks.ReentrantLock;class Solution {// synchronizedImpl使用的变量static Object lock = new Object();static int currentValue = 1;// Lock实现所需要的变量static ReentrantLock reentrantLock = new ReentrantLock();// volatile实现所需要的变量,volatile变量的单一操作，可以实现局部的同步效果// 但是volatile无法保证原子性，所以如果有i++这样的操作，volatile将会有问题// 也就是说，这里循环打印1/2，没有问题，但是如果题目是循环打印1~100的整数，就不可以单单用volatile了static volatile int currentXValue = 1;// AtomicInteger实现static AtomicInteger nAtomicInteger = new AtomicInteger(1);public static void main(String[] args) {// synchronizedImpl();// reentrantLockImpl();// volatileLockImpl();atomicIntegerImpl();}/** * * @Title: atomicIntegerImpl * @Description:AtomicInteger实现 * @author: itbird * @date 2022年3月16日 下午3:54:39 void */private static void atomicIntegerImpl() {Thread thread1 = new Thread(new Runnable() {@Overridepublic void run() {while (true) {if (nAtomicInteger.intValue() % 2 == 0) {System.out.println(Thread.currentThread().getName()+ " " + nAtomicInteger.intValue());nAtomicInteger.incrementAndGet();}try {Thread.sleep(200);} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}});Thread thread2 = new Thread(new Runnable() {@Overridepublic void run() {while (true) {if (nAtomicInteger.intValue() % 2 != 0) {System.out.println(Thread.currentThread().getName()+ " " + nAtomicInteger.intValue());nAtomicInteger.incrementAndGet();}try {Thread.sleep(200);} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}});thread1.start();thread2.start();}/** * * @Title: volatileLockImpl * @Description: volatile实现 * @author: itbird * @date 2022年3月16日 下午3:43:47 void */private static void volatileLockImpl() {Thread thread1 = new Thread(new Runnable() {@Overridepublic void run() {while (true) {if (currentXValue % 2 == 0) {System.out.println(Thread.currentThread().getName()+ " " + currentXValue);currentXValue++;}try {Thread.sleep(200);} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}});Thread thread2 = new Thread(new Runnable() {@Overridepublic void run() {while (true) {if (currentXValue % 2 != 0) {System.out.println(Thread.currentThread().getName()+ " " + currentXValue);currentXValue++;}try {Thread.sleep(200);} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}});thread1.start();thread2.start();}/** * * @Title: reentrantLockImpl * @Description: ReentrantLock实现方式 * @author: itbird * @date 2022年3月16日 下午3:40:30 void */private static void reentrantLockImpl() {Thread thread1 = new Thread(new Runnable() {@Overridepublic void run() {while (true) {try {reentrantLock.lock();if (currentValue % 2 != 0) {System.out.println(Thread.currentThread().getName()+ " " + currentValue);currentValue++;}} finally {reentrantLock.unlock();}try {Thread.sleep(200);} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}});Thread thread2 = new Thread(new Runnable() {@Overridepublic void run() {while (true) {try {reentrantLock.lock();if (currentValue % 2 == 0) {System.out.println(Thread.currentThread().getName()+ " " + currentValue);currentValue++;}} finally {reentrantLock.unlock();}try {Thread.sleep(200);} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}});thread1.start();thread2.start();}/** * @Title: synchronizedImpl * @Description: synchronized实现方式 * @author: itbird * @date 2022年3月16日 下午3:14:43 void */public static void synchronizedImpl() {Thread thread1 = new Thread(new Runnable() {@Overridepublic void run() {while (true) {synchronized (lock) {if (currentValue % 2 != 0) {System.out.println(Thread.currentThread().getName()+ " " + currentValue);currentValue++;lock.notify();} else {try {lock.wait();} catch (InterruptedException e) {e.printStackTrace();}}try {Thread.sleep(200);} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}}});Thread thread2 = new Thread(new Runnable() {@Overridepublic void run() {while (true) {synchronized (lock) {if (currentValue % 2 == 0) {System.out.println(Thread.currentThread().getName()+ " " + currentValue);currentValue++;lock.notify();} else {try {lock.wait();} catch (InterruptedException e) {e.printStackTrace();}}try {Thread.sleep(200);} catch (InterruptedException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}}});thread1.start();thread2.start();}}