这是我的部分代码:
if (bufferList.size() < 500) {
bufferList.add(song);
} else {
synchronized (this) {
try {
// 为了性能,用SpringJDBC
Date date = new Date();
batchInsertSelective(bufferList);
Date date1 = new Date();
System.out.println("[INFO] 线程\t" + Thread.currentThread().getId() + "\t本次插入所花时间:\t" + (date1.getTime() - date.getTime()));
bufferList.clear();
objectCount += bufferList.size();
} catch (Exception e) {
e.printStackTrace();
logger.error(e.getMessage());
}
}
}
情景:多个线程访问这一段代码,如果缓存List大小大于500就调用batchInsertSelective将数据批量导入数据库,为了测试,我加上了两个时间用来测试insert的时间,并打印。因为加了锁,所以数据库并没有出现重复的问题。但打印的时候问题来了:
[INFO] 线程 57 本次插入所花时间: 1106
[INFO] 线程 89 本次插入所花时间: 0
[INFO] 线程 36 本次插入所花时间: 0
[INFO] 线程 45 本次插入所花时间: 0
[INFO] 线程 76 本次插入所花时间: 0
[INFO] 线程 42 本次插入所花时间: 0
[INFO] 线程 58 本次插入所花时间: 0
[INFO] 线程 86 本次插入所花时间: 0
[INFO] 线程 67 本次插入所花时间: 0
[INFO] 线程 81 本次插入所花时间: 0
[INFO] 线程 64 本次插入所花时间: 0
[INFO] 线程 79 本次插入所花时间: 0
[INFO] 线程 71 本次插入所花时间: 0
[INFO] 线程 88 本次插入所花时间: 0
打印的时候会显示这样(数据库数据没有受到此问题的影响,没有重复值)。
求助大神解答一下。
不要用 Date, 用Java.lang.System.currentTimeMillis()
Date精确到秒, 用毫秒
是一个很简单的问题,是因为刚接触并发的原因,有些地方还不太熟悉。
是因为当有一个线程进入synchronized代码块后,其余县城到了else阻塞了(等待获取锁),当第一个线程释放锁后,bufferList清零。其余线程依次获取锁,执行synchronized代码块,因为bufferList为0,所以执行的特别快。
修改方式:把synchronized套住整个if&else。