目录
一、背景介绍
1.从reids中读取数据拼接url地址,存在地址拼接不全的问题
2.遇到并发的情况会产生大量的对象被创建,导致cpu飙升
二、分析问题
三、如何解决
问题复现
1.操作类
2.启动类,用100个线程模拟并发的情况
3.运行结果,出现了数据混乱的情况。
解决问题
1.使用synchronized优化代码
2.使用ThreadLocal
3.使用removeAll方法解决创建大量对象问题
四、总结提升
一、背景介绍
1.从reids中读取数据拼接url地址,存在地址拼接不全的问题
2.遇到并发的情况会产生大量的对象被创建,导致cpu飙升
二、分析问题
两个问题是有前后关系的,当有并发请求到该业务的时候,由于keyList是一个全局变量,别的方法也会对他进行操作,这样就会有第一个方法还没有操作完第二个方法紧接着又进行了操作。最后导致我们拼接出来的key值在redis中是读取不到的。从而出现了拼接url地址确实的问题。对于产生大量的对象,也是由并发造成的,第一个对象刚创建出来,紧接着有创建了第二个对象。又因为对象复制给了一个公共变量,导致上一个对象失去了引用,等待垃圾回收器进行回收。从而cpu直线飙升。
三、如何解决
问题复现
1.操作类
public class Count {
List<String> content=new ArrayList<>();
public void getContent(){
content = new ArrayList<>();
content.add("1");
content.add("2");
content.add("3");
content.add("4");
System.out.println("wzill"+content);
}
}
2.启动类,用100个线程模拟并发的情况
public class Client {
public static void main(String[] args) {
// 定义线程实现接口
Runnable runnable = new Runnable(){
Count counter = new Count();
@Override
public void run() {
try {
counter.getContent();
} catch (Exception e) {
throw new RuntimeException(e);
}
}
};
// 启动100个线程
for( int i= 0;i< 100;i++) {
new Thread(runnable).start();
}
}
}
3.运行结果,出现了数据混乱的情况。
解决问题
1.使用synchronized优化代码
某一时刻只有一个线程在执行,来确保线程数据的安全性。
public class Count {
List<String> content=new ArrayList<>();
public synchronized void getContent(){
content = new ArrayList<>();
content.add("1");
content.add("2");
content.add("3");
content.add("4");
System.out.println("wzill"+content);
}
}
2.使用ThreadLocal
public class Count {
private static ThreadLocal<List<String>> keyList = new ThreadLocal<List<String>>(){
//对keyList进行初始化
@Override public List<String> initialValue() {
return new ArrayList<String>();
}
};
public synchronized void getContent(){
keyList.get().add("1");
keyList.get().add("2");
keyList.get().add("3");
keyList.get().add("4");
System.out.println("wzill"+keyList.get());
}
}
3.使用removeAll方法解决创建大量对象问题
//声明一个全局变量,ArrayList线程不安全
List<String> keyList=new ArrayList<>();
public synchronized void count2() throws InterruptedException {
keyList.add("a");
keyList.add("b");
keyList.add("c");
keyList.add("d");
System.out.println("ARPRO"+keyList);
//由于虽然使用synchronized锁住了count2()这个方法保证同一时刻只有一个线程执行
//但是线程共享全局变量,所以当方法执行完成之后,需要将keyList的值进行还原
keyList.removeAll(keyList);
}
四、总结提升
使用全局变量时要慎重,考虑他的作用域以及影响的内容。添加必要的说明,因为作用域大了别人也可以使用这个变量,减少别人使用对之前的业务产生影响。