/** To change this license header, choose License Headers in Project Properties.* To change this template file, choose Tools | Templates* and open the template in the editor.*/
package cn.edu.scau.mk.map;import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;/**** @author MK*/
public class ConcurrentLockMap implements In {ConcurrentHashMap<Integer, Integer> map = new ConcurrentHashMap<>();Lock lock = new ReentrantLock();@Overridepublic void add(int a) {lock.lock();try {if (map.containsKey(a)) {map.put(a, 1 + map.get(a));} else {map.put(a, 1);}} finally {lock.unlock();}}@Overridepublic int get(int a) {int as = map.get(a);return as;}}

package cn.edu.scau.mk.map;import java.util.concurrent.ConcurrentHashMap;/**** @author MK*/
public class ConcurrentSynchronizedMap implements In {ConcurrentHashMap<Integer, Integer> map = new ConcurrentHashMap<>();@Overridepublic void add(int a) {synchronized ((""+a).intern()) {if (map.containsKey(a)) {map.put(a, 1 + map.get(a));} else {map.put(a, 1);}}}@Overridepublic int get(int a) {int as = map.get(a);return as;}}

package cn.edu.scau.mk.map;import java.util.HashMap;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;/**** @author MK*/
public class LockHashMap implements In {HashMap<Integer, Integer> map = new HashMap<>();Lock lock = new ReentrantLock();@Overridepublic void add(int a) {lock.lock();try {if (map.containsKey(a)) {map.put(a, 1 + map.get(a));} else {map.put(a, 1);}} finally {lock.unlock();}}@Overridepublic int get(int a) {int as = 0;lock.lock();try {map.get(a);} finally {lock.unlock();}return as;}}

/** To change this license header, choose License Headers in Project Properties.* To change this template file, choose Tools | Templates* and open the template in the editor.*/
package cn.edu.scau.mk.map;import java.util.HashMap;
import java.util.concurrent.locks.ReentrantReadWriteLock;/**** @author MK*/
public class ReadWriteHashMap implements In {HashMap<Integer, Integer> map = new HashMap<>();ReentrantReadWriteLock lock = new ReentrantReadWriteLock();//390
@Overridepublic void add(int a) {lock.writeLock().lock();try {if (map.containsKey(a)) {map.put(a, 1 + map.get(a));} else {map.put(a, 1);}} finally {lock.writeLock().unlock();}}@Overridepublic int get(int a) {int as = 0;lock.readLock().lock();try {as = map.get(a);} finally {lock.readLock().unlock();}return as;}}

/** To change this license header, choose License Headers in Project Properties.* To change this template file, choose Tools | Templates* and open the template in the editor.*/
package cn.edu.scau.mk.map;import java.util.HashMap;/**** @author MK*/
public class SynchronizedHashMap implements In {HashMap<Integer, Integer> map = new HashMap<>();@Overridepublic synchronized void add(int a) {if (map.containsKey(a)) {map.put(a, 1 + map.get(a));} else {map.put(a, 1);}}@Overridepublic synchronized int get(int a) {int as = map.get(a);return as;}}

package cn.edu.scau.mk.map;/**** @author MK*/
public interface In {void add(int a);int get(int a);}

/** To change this license header, choose License Headers in Project Properties.* To change this template file, choose Tools | Templates* and open the template in the editor.*/
package cn.edu.scau.mk.map;import java.util.Random;/**** @author MK*/
public class Adder implements Runnable {In in;Random random = new Random();public Adder(In in) {this.in=in;}@Overridepublic void run() {for (int i = 0; i < 1000; i++) {//in.add(random.nextInt());
            in.add(i);}}
}

/** To change this license header, choose License Headers in Project Properties.* To change this template file, choose Tools | Templates* and open the template in the editor.*/
package cn.edu.scau.mk.map;import java.util.Random;/**** @author MK*/
public class Getter implements Runnable {In in;Random random = new Random();public Getter(In in) {this.in=in;}@Overridepublic void run() {for (int i = 0; i < 1000; i++) {//in.add(random.nextInt());
            in.get(i);}}
}

package cn.edu.scau.mk.map;import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;/**** @author MK*/
public class TestDemo {public static void main(String[] args) {In in = null;in = new ReadWriteHashMap();operate(in);in = new ConcurrentSynchronizedMap();operate(in);in = new ConcurrentLockMap();operate(in);in = new SynchronizedHashMap();operate(in);in = new LockHashMap();operate(in);}public static void operate(In in) {int poolSize = 1000000;Adder add = new Adder(in);ThreadPoolExecutor threadPool = (ThreadPoolExecutor) Executors.newCachedThreadPool();long start = System.currentTimeMillis();for (int i = 0; i < poolSize; i++) {threadPool.execute(add);}System.out.println(threadPool.getActiveCount());threadPool.shutdown();try {//等待直到所有任务完成
            threadPool.awaitTermination(Long.MAX_VALUE, TimeUnit.MINUTES);long end = System.currentTimeMillis() - start;System.out.print(in.getClass().getSimpleName()+" add:" + end);} catch (InterruptedException e) {e.printStackTrace();}Getter get = new Getter(in);threadPool = (ThreadPoolExecutor) Executors.newCachedThreadPool();start = System.currentTimeMillis();for (int i = 0; i < poolSize; i++) {threadPool.execute(add);}threadPool.shutdown();try {//等待直到所有任务完成
            threadPool.awaitTermination(Long.MAX_VALUE, TimeUnit.MINUTES);long end = System.currentTimeMillis() - start;System.out.println(" get:" + end);} catch (InterruptedException e) {e.printStackTrace();}}
}