Skip to content

Commit 087b990

Browse files
Add files via upload
1 parent 44826a4 commit 087b990

4 files changed

+96
-0
lines changed

ConcurrentHashMapMethods33.java

+24
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
import java.util.concurrent.ConcurrentHashMap;
2+
3+
public class ConcurrentHashMapMethods33 {
4+
5+
//search​(long parallelismThreshold, BiFunction<? super K,​? super V,​? extends U> searchFunction)
6+
public static void main(String[] args) throws Exception {
7+
ConcurrentHashMap<String, String> map = new ConcurrentHashMap<>();
8+
map.put("one", "1");
9+
map.put("two", "2");
10+
map.put("three", "3");
11+
map.put("four", "4");
12+
System.out.println("Map:" + map);
13+
14+
String result = map.search(2, (k, v) -> {
15+
System.out.println("Key:" + k + " Value:" + v);
16+
if (k.equals("three")) {
17+
return v;
18+
}
19+
return null;
20+
});
21+
System.out.println("Result:" + result);
22+
}
23+
24+
}

ConcurrentHashMapMethods34.java

+23
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,23 @@
1+
import java.util.concurrent.ConcurrentHashMap;
2+
public class ConcurrentHashMapMethods34 {
3+
//searchEntries​(long parallelismThreshold, Function<Map.Entry<K,​V>,​? extends U> searchFunction)
4+
5+
public static void main(String[] args) throws Exception {
6+
ConcurrentHashMap<String, String> map = new ConcurrentHashMap<>();
7+
map.put("one", "1");
8+
map.put("two", "2");
9+
map.put("three", "3");
10+
map.put("four", "4");
11+
System.out.println("Map:" + map);
12+
13+
String result = map.searchEntries(2, (entry) -> {
14+
System.out.println("Key:" + entry.getKey() + " Value:" + entry.getValue());
15+
if (entry.getKey().equals("three")) {
16+
return entry.getValue();
17+
}
18+
return null;
19+
});
20+
System.out.println("Result:" + result);
21+
}
22+
23+
}

ConcurrentHashMapMethods35.java

+25
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,25 @@
1+
2+
import java.util.concurrent.ConcurrentHashMap;
3+
public class ConcurrentHashMapMethods35 {
4+
5+
//searchKeys​(long parallelismThreshold, Function<? super K,​? extends U> searchFunction)
6+
7+
public static void main(String[] args) throws Exception {
8+
ConcurrentHashMap<Integer, String> map = new ConcurrentHashMap<>();
9+
map.put(1, "1");
10+
map.put(2, "2");
11+
map.put(3, "3");
12+
map.put(4, "4");
13+
System.out.println("Map:" + map);
14+
15+
Integer result = map.searchKeys(2, k -> {
16+
System.out.println("Key:" + k);
17+
if (k == 3) {
18+
return k;
19+
}
20+
return null;
21+
});
22+
System.out.println("Result:" + result);
23+
}
24+
25+
}

ConcurrentHashMapMethods36.java

+24
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
import java.util.concurrent.ConcurrentHashMap;
2+
public class ConcurrentHashMapMethods36 {
3+
4+
//searchValues​(long parallelismThreshold, Function<? super V,​? extends U> searchFunction)
5+
6+
public static void main(String[] args) throws Exception {
7+
ConcurrentHashMap<Integer, String> map = new ConcurrentHashMap<>();
8+
map.put(1, "1");
9+
map.put(2, "2");
10+
map.put(3, "3");
11+
map.put(4, "4");
12+
System.out.println("Map:" + map);
13+
14+
String result = map.searchValues(2, v -> {
15+
System.out.println("Value:" + v);
16+
if (v.equals("3")) {
17+
return v;
18+
}
19+
return null;
20+
});
21+
System.out.println("Result:" + result);
22+
}
23+
24+
}

0 commit comments

Comments
 (0)