开发过程当中,为了提交系统效率,会使用一些多线程技术,好比消息队列、异步service等,虽然提升了系统效率,同时也大大增长了并发几率。
加锁是最快的解决办法,加锁的方式有不少种,本文不作过多讨论。
本文主要记录以字符串为锁对象的一个示例和一些注意事项。
话很少说,示例以下:java
package com.xiang.test; import java.util.concurrent.BrokenBarrierException; import java.util.concurrent.CyclicBarrier; import org.apache.commons.lang3.RandomUtils; public class MainTest { public static void main(String[] args) { MainTest test = new MainTest(); test.syncTest(); } public void syncTest() { String[] keys = { "1", "2", "3", "4", "5" }; int oneThreadCnt = 10; CyclicBarrier cyclicBarrier = new CyclicBarrier(14); for (int i = 0; i < oneThreadCnt; i++) { String key = (i >= keys.length) ? keys[i - keys.length] : keys[i]; key = key + "xxx"; Thread tempThread = new Thread(new syncTest(cyclicBarrier, key)); tempThread.setName("Td-" + i); tempThread.start(); } new Thread(new syncTest(cyclicBarrier, "3")).start();// 有锁的效果 new Thread(new syncTest(cyclicBarrier, "2")).start();// 有所的效果 new Thread(new syncTest(cyclicBarrier, new String("1"))).start();// 没有锁的效果 new Thread(new syncTest(cyclicBarrier, new String("5"))).start();// 没有锁的效果 } class syncTest implements Runnable { private CyclicBarrier cyclicBarrier; private String key; private String x = "ccc"; public syncTest(CyclicBarrier cyclicBarrier, String key) { this.cyclicBarrier = cyclicBarrier; this.key = key; } @Override public void run() { try { cyclicBarrier.await(); // String syncKey = key + x;// 不能达到锁的效果 String syncKey = buildSyncKey(key, x);// 能够锁 // synchronized (key) {//能够锁 synchronized (syncKey) { long sleepMillis = RandomUtils.nextLong(3000, 10000); System.out.println(Thread.currentThread().getName() + "启动,当前时间:" + System.currentTimeMillis() + "当前是" + key + ",预计休眠时间:" + sleepMillis + ",key.hash:" + key.hashCode()); Thread.sleep(sleepMillis); } } catch (InterruptedException | BrokenBarrierException e1) { e1.printStackTrace(); } } private String buildSyncKey(String... keys) { StringBuilder sb = new StringBuilder(); for (String string : keys) { sb.append(string); } return sb.toString().intern(); } } }
注意事项:
如下这种写法是达不到锁的效果的,由于 syncKey每次产生的是一个新的对象。
String syncKey = key + x;
synchronized (syncKey) {}apache
只有保证两个字符串变量最终结果是同一个对象时锁才能生效
最方便的解决办法是使用字符串的intern()方法。多线程
intern() 返回常量池中的字符串对象,相同两个字符串的值相同,则返回的是同一个对象并发
此问题的示例能够参见转载资料:
java+内存分配及变量存储位置的区别: https://blog.csdn.net/rj042/a...
String常量池问题的几个例子:https://blog.csdn.net/gaopeng...app