多线程环境下，会出现线程不安全的问题，所以要对某些方法加锁以保证线程安全
但是如果方法过多，每个方法前后都加这么一句，有点麻烦了，而且代码可读性也会差一些。可以使用aop切面编程，对某些加有特定注解（自定义注解）的方法做加锁操作即可。
自定义注解
@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);//互斥锁 参数默认false，不公平锁
/**
* 思考：为什么不用synchronized
* service 默认是单例的，并发下lock只有一个实例
*/
//Service层切点 用于记录错误日志
@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;
}
}
下图中箭头处改为自己的自定义注解类的全路径,就是包名加类名
准备测试,用售票的例子
@Service
public class Ticket1 implements Runnable {
private int tickets = 100;
@Override
@Lock
public void run() {
while (tickets > 0) {
// synchronized (Ticket.class) {
if (tickets > 0) {
tickets--;
System.out.println(Thread.currentThread().getName() + "正在卖票，还剩下" + tickets + "张");
}
// }
try {
// 休眠一秒，让执行的效果更明显
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
服务器托管，北京服务器托管，服务器租用 http://www.fwqtg.net
机房租用，北京机房租用，IDC机房托管， http://www.e1idc.net
