java高级开发 关键字AtomicBoolean

版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/DTJ_74/article/details/88068821

AtomicBoolean :关键字

package com.tc.pro;

import java.util.Timer;
import java.util.TimerTask;
import java.util.concurrent.atomic.AtomicBoolean;

public class Dpro {
	//  1.保证某段语句只执行一次。
	// 首先我们要知道compareAndSet的作用,判断对象当时内部值是否为第一个参数,
	// 如果是则更新为第二个参数,且返回ture,否则返回false。那么默认初始化为false,
	// 则一个线程把他变为ture,compareAndSet返回ture,进入方法体执行逻辑,
	// 那么其他的任何线程进入该方法执行compareAndSet时第一个参数为false,
	// 而对象的内部值已经被修改为true,则永远过不了if。

	private static AtomicBoolean mRefreshing = new AtomicBoolean(false); // 进行线程同步
	// 因为AtomicBoolean的compareAndSet这个方法是原子性操作,
	// 首先判断当前值是否与expect的值相等,如果相等则把值更新update
	private static String token = null;
	static Runnable isRunnable = new Runnable() {
		@Override
		public void run() {
			getWork();
		}
	};
	static Runnable isRunnable2 = new Runnable() {
		@Override
		public void run() {
			getWork2();
		}
	};

	public static void main(String[] args) {
		new Thread(isRunnable).start();
		Timer timer = new Timer();
		timer.schedule(new TimerTask() {
			public void run() {
				new Thread(isRunnable2).start();
			}
		}, 5000);// 设定指定的时间time,此处为5000毫秒
	
	}
	private static void getWork2() {
		if (mRefreshing.compareAndSet(false, true)) {
			Timer timer = new Timer();
			timer.schedule(new TimerTask() {
				public void run() {
					System.out.println("-------设定要指定任务--------");
					System.out.println("张三挖矿,李白不能挖");
					mRefreshing.compareAndSet(false, true);
				}
			}, 3000);// 设定指定的时间time,此处为2000毫秒
			log();
		}
	}
	private static void getWork() {
		if (mRefreshing.compareAndSet(false, true)) {
			Timer timer = new Timer();
			timer.schedule(new TimerTask() {
				public void run() {
					System.out.println("-------设定要指定任务--------");
					System.out.println("李白挖矿3秒,张三不能挖");
					mRefreshing.compareAndSet(true, false);
				}
			}, 3000);// 设定指定的时间time,此处为2000毫秒
			log();
		}
	}

	private static void log() {
		System.out.println("获取Id:" + Thread.currentThread().getId());
		System.out.println("获取名称:" + Thread.currentThread().getName());
	}

}

开两个线程,测试,就是锁住当前线程这样子的作用,可以用于并发请求时候,token失效了。要刷新token

再进行原来的请求。那么如果是并发 请求刷新token 那个接口是毫无必要的,因为只要刷一次就可以了。

猜你喜欢

转载自blog.csdn.net/DTJ_74/article/details/88068821