自定义注解,aop实现注解锁
生活随笔
收集整理的這篇文章主要介紹了
自定义注解,aop实现注解锁
小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.
多線程環(huán)境下,會(huì)出現(xiàn)線程不安全的問題,所以要對(duì)某些方法加鎖以保證線程安全
但是如果方法過多,每個(gè)方法前后都加這么一句,有點(diǎn)麻煩了,而且代碼可讀性也會(huì)差一些。可以使用aop切面編程,對(duì)某些加有特定注解(自定義注解)的方法做加鎖操作即可。
自定義注解
@Target({ElementType.PARAMETER, ElementType.METHOD}) @Retention(RetentionPolicy.RUNTIME) @Documented public @interface Lock {String description() default ""; }?
定義切面類
public class LockAspect {private static Lock lock = new ReentrantLock(false);//互斥鎖 參數(shù)默認(rèn)false,不公平鎖/*** 思考:為什么不用synchronized* service 默認(rèn)是單例的,并發(fā)下lock只有一個(gè)實(shí)例*///Service層切點(diǎn) 用于記錄錯(cuò)誤日志@Pointcut("@annotation(com.example.thread.threaddemo.Lock)")public void lockAspect() {}@Around("lockAspect()")public Object around(ProceedingJoinPoint joinPoint) {lock.lock();Object obj = null;try {obj = joinPoint.proceed();} catch (Throwable e) {e.printStackTrace();} finally {lock.unlock();}return obj;} }下圖中箭頭處改為自己的自定義注解類的全路徑,就是包名加類名?
準(zhǔn)備測試,用售票的例子 @Service public class Ticket1 implements Runnable {private int tickets = 100;@Override@Lockpublic void run() {while (tickets > 0) { // synchronized (Ticket.class) {if (tickets > 0) {tickets--;System.out.println(Thread.currentThread().getName() + "正在賣票,還剩下" + tickets + "張");} // }try {// 休眠一秒,讓執(zhí)行的效果更明顯Thread.sleep(100);} catch (InterruptedException e) {e.printStackTrace();}}}public static void main(String[] args) {Ticket1 ticket = new Ticket1();Thread t1 = new Thread(ticket, "窗口一:");Thread t2 = new Thread(ticket, "窗口二:");Thread t3 = new Thread(ticket, "窗口三:");t1.start();t2.start();t3.start();} }?
把synchronized鎖的代碼注釋掉了,還需要在方法上加上自定義注解 @Lock
?
總結(jié)
以上是生活随笔為你收集整理的自定义注解,aop实现注解锁的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: ListString^^ 引用空间
- 下一篇: 取消数据源的自动创建,使用Seata对数