两个线程按顺序打印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() {
			@Override
			public 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 block
						e.printStackTrace();
					}
				}
			}
		});
		Thread thread2 = new Thread(new Runnable() {
			@Override
			public 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 block
						e.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() {
			@Override
			public 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 block
						e.printStackTrace();
					}
				}
			}
		});
		Thread thread2 = new Thread(new Runnable() {
			@Override
			public 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 block
						e.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() {
			@Override
			public 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 block
						e.printStackTrace();
					}
				}
			}
		});
		Thread thread2 = new Thread(new Runnable() {
			@Override
			public 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 block
						e.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() {
			@Override
			public 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 block
							e.printStackTrace();
						}
					}
				}
			}
		});
		Thread thread2 = new Thread(new Runnable() {
			@Override
			public 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 block
							e.printStackTrace();
						}
					}
				}
			}
		});
		thread1.start();
		thread2.start();
	}
}