首页 > Java开发 > HashMap的并发问题

HashMap的并发问题

先上一段代码

[java]

  1. public class CurrMap {  
  2.   
  3.     /** 线程池 */  
  4.   
  5.     private static final Executor EXECUTOR = Executors.newFixedThreadPool(20);  
  6.   
  7.     /** 
  8.      *  
  9.      * @param args 
  10.      */  
  11.     public static void main(String[] args) {  
  12.   
  13.         //      final  Map<String, String> map = new ConcurrentHashMap<String, String>();  
  14.         final Map<String, String> map = new HashMap<String, String>();  
  15.         map.put("laotu""handsome");  
  16.         final Random random = new Random();  
  17.   
  18.         while (true) {  
  19.   
  20.             EXECUTOR.execute(new Runnable() {  
  21.                 public void run() {  
  22.   
  23.                     for (int i = 0; i < 1000; i++) {  
  24.                         try {  
  25.                             TimeUnit.MILLISECONDS.sleep(1);  
  26.                         } catch (InterruptedException ex) {  
  27.                             System.err.println("t5 catch the InterruptedException...");  
  28.                         }  
  29.                         for (String key : map.keySet()) {  
  30.                         }  
  31.                     }  
  32.   
  33.                 }  
  34.             });  
  35.   
  36.             for (int i = 0; i < 100; i++) {  
  37.   
  38.                 EXECUTOR.execute(new Runnable() {  
  39.   
  40.                     public void run() {  
  41.   
  42.                         for (int i = 0; i < 1000; i++) {  
  43.                             try {  
  44.                                 TimeUnit.MILLISECONDS.sleep(1);  
  45.                             } catch (InterruptedException ex) {  
  46.                                 System.err.println("t1 catch the InterruptedException...");  
  47.                             }  
  48.                             int key = random.nextInt(1000);  
  49.                             map.put(String.valueOf(key), String.valueOf(key));  
  50.                         }  
  51.                     }  
  52.   
  53.                 });  
  54.   
  55.             }  
  56.         }  
  57.   
  58.     }  
  59.   
  60. }  


执行结果:

[html]

  1. Exception in thread "pool-1-thread-1" java.util.ConcurrentModificationException  
  2.     at java.util.HashMap$HashIterator.nextEntry(HashMap.java:793)  
  3.     at java.util.HashMap$KeyIterator.next(HashMap.java:828)  
  4.     at com.alipay.ctu.biz.intl.filters.CurrMap$1.run(CurrMap.java:52)  
  5.     at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)  
  6.     at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)  
  7.     at java.lang.Thread.run(Thread.java:695)  

尝试以下两种方案:

a. 把HashMap更换为ConcurrentHashMap,然后执行.

b. 仍使用HashMap, 注释掉第一段EXECUTOR.execute 的代码,然后执行。

结果呢:

方案a肯定不会报这个错。方案b应该不会报这个错,但是存在极小的可能会报这个错。

应用场景:

一笔交易支付事件过来,事件类型为HashMap,我们需要对卡信息,IP信息等进行信息补全,通过线程池并发执行信息补全的过程中,在每个线程内部执行了map.put(key,value)的操作,因此在高并发情况下会可能会抛出异常java.util.ConcurrentModificationException。(出现概率低)

如果此时在线程中执行map.keySet() 操作,遍历map中的数据,那么出现异常java.util.ConcurrentModificationException的概率就很高了。

如果使用HashMap,我们已经清楚不是线程安全的了,那么可能会出现什么问题呢?

a. put 的数据丢失。

b. remove 的数据未被清除,仍然存在。

c. HashMap resize 导致存在性能问题。

d. get 数据时出现死循环。

解决方案:

推荐使用ConcurrentHashMap。

 


本文固定链接: http://www.devba.com/index.php/archives/4355.html | 开发吧

报歉!评论已关闭.