This Java program is to Implement ConcurrentHashMap API.A hash table supporting full concurrency of retrievals and adjustable expected concurrency for updates. This class obeys the same functional specification as Hashtable, and includes versions of methods corresponding to each method of Hashtable. However, even though all operations are thread-safe, retrieval operations do not entail locking, and there is not any support for locking the entire table in a way that prevents all access.
Here is the source code of the Java program to Implement ConcurrentHashMap API. The Java program is successfully compiled and run on a Linux system. The program output is also shown below.
import java.util.Collection; import java.util.Enumeration; import java.util.HashMap; import java.util.Iterator; import java.util.Map; import java.util.Map.Entry; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; public class ConcurrentHashMapImpl<K, V> { private ConcurrentHashMap<K, V> concurrentHashMap; /** * Constructs an empty insertion-ordered LinkedHashMap instance with the * default initial capacity (16) and load factor (0.75). **/ public ConcurrentHashMapImpl() { concurrentHashMap = new ConcurrentHashMap<K, V>(); } /** * Constructs an empty insertion-ordered LinkedHashMap instance with the * specified initial capacity and a default load factor (0.75). **/ public ConcurrentHashMapImpl(int initialCapacity) { concurrentHashMap = new ConcurrentHashMap<K, V>(initialCapacity); } /** * Constructs an empty insertion-ordered LinkedHashMap instance with the * specified initial capacity and load factor. **/ public ConcurrentHashMapImpl(int initialCapacity, float loadFactor) { concurrentHashMap = new ConcurrentHashMap<K, V>(initialCapacity, loadFactor); } /** * Constructs an empty LinkedHashMap instance with the specified initial * capacity, load factor and ordering mode. **/ public ConcurrentHashMapImpl(int initialCapacity, float loadFactor, int concurrencyLevel) { concurrentHashMap = new ConcurrentHashMap<K, V>(initialCapacity, loadFactor, concurrencyLevel); } /** * Constructs an insertion-ordered LinkedHashMap instance with the same * mappings as the specified map. **/ public ConcurrentHashMapImpl(Map<? extends K, ? extends V> m) { concurrentHashMap = new ConcurrentHashMap<K, V>(m); } /** Removes all of the mappings from this map. **/ public void clear() { concurrentHashMap.clear(); } /** Returns true if this map contains a mapping for the specified key. **/ public boolean containsKey(Object key) { return concurrentHashMap.containsKey(key); } /** Returns true if this map maps one or more keys to the specified value. **/ public boolean containsValue(Object value) { return concurrentHashMap.containsValue(value); } /** Returns a Set view of the mappings contained in this map. **/ public Set<Map.Entry<K, V>> entrySet() { return concurrentHashMap.entrySet(); } /** * Returns the value to which the specified key is mapped, or null if this * map contains no mapping for the key. **/ public V get(Object key) { return concurrentHashMap.get(key); } /** Returns true if this map contains no key-value mappings. **/ public boolean isEmpty() { return concurrentHashMap.isEmpty(); } /** Returns a Set view of the keys contained in this map. **/ public Set<K> keySet() { return concurrentHashMap.keySet(); } /** Associates the specified value with the specified key in this map. **/ public V put(K key, V value) { return concurrentHashMap.put(key, value); } /** Copies all of the mappings from the specified map to this map. **/ public void putAll(Map<? extends K, ? extends V> m) { concurrentHashMap.putAll(m); } /** Removes the mapping for the specified key from this map if present. **/ public V remove(Object key) { return concurrentHashMap.remove(key); } /** Returns the number of key-value mappings in this map. **/ public int size() { return concurrentHashMap.size(); } /** Returns a Collection view of the values contained in this map. **/ public Collection<V> values() { return concurrentHashMap.values(); } /** Returns an enumeration of the values in this table. **/ public Enumeration<V> elements() { return concurrentHashMap.elements(); } /** * If the specified key is not already associated with a value, associate it * with the given value. **/ public V putIfAbsent(K key, V value) { return concurrentHashMap.putIfAbsent(key, value); } /** Replaces the entry for a key only if currently mapped to some value. **/ public V replace(K key, V value) { return concurrentHashMap.replace(key, value); } /** Replaces the entry for a key only if currently mapped to a given value. **/ public boolean replace(K key, V oldValue, V newValue) { return concurrentHashMap.replace(key, oldValue, newValue); } public static void main(String... arg) { ConcurrentHashMapImpl<Integer, Integer> concurrentHashMap = new ConcurrentHashMapImpl<Integer, Integer>(); concurrentHashMap.put(1, 100); concurrentHashMap.put(2, 200); concurrentHashMap.put(3, 300); concurrentHashMap.put(4, 400); Map<Integer, Integer> anotherMap = new HashMap<Integer, Integer>(); concurrentHashMap.putAll(anotherMap); System.out.println("the key set of the concurrentHashMap is "); Set<Integer> keySet = concurrentHashMap.keySet(); Iterator<Integer> itr = keySet.iterator(); while (itr.hasNext()) { System.out.print(itr.next() + "\t"); } System.out.println(); System.out.println("the values of the concurrentHashMap is "); Collection<Integer> collectionValues = concurrentHashMap.values(); itr = collectionValues.iterator(); while (itr.hasNext()) { System.out.print(itr.next() + "\t"); } System.out.println(); System.out.println("the entry set of the concurrentHashMap is "); Iterator<Entry<Integer, Integer>> eitr; Set<Entry<Integer, Integer>> entrySet = concurrentHashMap.entrySet(); eitr = entrySet.iterator(); while (eitr.hasNext()) { System.out.println(eitr.next() + "\t"); } System.out.println("the concurrentHashMap contains Key 3 :" + concurrentHashMap.containsKey(3)); System.out.println("the concurrentHashMap contains Value 600 :" +courrentHashMap.containsValue(600)); System.out.println("Put the key 10 with value 1000 if not asscociated : " + concurrentHashMap.putIfAbsent(10, 1000)); System.out.println("replace key 3 oldvalue of 300 and newvalue 500 :" + concurrentHashMap.replace(3, 300, 500)); System.out.println("the size of the concurrentHashMap is " + concurrentHashMap.size()); concurrentHashMap.clear(); if (concurrentHashMap.isEmpty()) System.out.println("the concurrentHashMap is empty"); else System.out.println("the concurrentHashMap is not empty"); } }
$ javac ConcurrentHashMapImpl.java $ java ConcurrentHashMapImpl the key set of the concurrentHashMap is 2 1 3 4 the values of the concurrentHashMap is 200 100 300 400 the entry set of the concurrentHashMap is 2=200 1=100 3=300 4=400 the concurrentHashMap contains Key 3 :true the concurrentHashMap contains Value 600 :false Put the key 10 with value 1000 if not asscociated : null replace key 3 oldvalue of 300 and newvalue 500 :true the size of the concurrentHashMap is 5 the concurrentHashMap is empty
Related posts:
Debug a JavaMail Program
Java Program to Repeatedly Search the Same Text (such as Bible by building a Data Structure)
Java Scanner hasNext() vs. hasNextLine()
Introduction to Using Thymeleaf in Spring
Java Program to Implement LinkedBlockingDeque API
Java Multi-line String
Java Program to Generate All Subsets of a Given Set in the Gray Code Order
Java Program to Implement Find all Back Edges in a Graph
Lập trình đa luồng với CompletableFuture trong Java 8
Netflix Archaius with Various Database Configurations
Upload and Display Excel Files with Spring MVC
Introduction to the Java ArrayDeque
Spring Boot - Web Socket
Java Program to Find the Edge Connectivity of a Graph
Java Program to Implement Unrolled Linked List
Java Stream Filter with Lambda Expression
Java Timer
Java Program to Implement Heap Sort Using Library Functions
How to Read HTTP Headers in Spring REST Controllers
Spring Boot - Interceptor
Integer Constant Pool trong Java
Hướng dẫn Java Design Pattern – Service Locator
Giới thiệu SOAP UI và thực hiện test Web Service
Java Program to Find k Numbers Closest to Median of S, Where S is a Set of n Numbers
Java Program to Check whether Undirected Graph is Connected using DFS
Testing in Spring Boot
Creating a Web Application with Spring 5
Java String to InputStream
Java Program to Implement Stack using Two Queues
Java Program to find the peak element of an array using Binary Search approach
Queue và PriorityQueue trong Java
Java Program to Implement Binary Heap