提交 cfd65a93 编写于 作者: N Nikita Koksharov

MapLoader check in RMap.loadAll methods.

上级 feb8295c
...@@ -1200,6 +1200,10 @@ public class RedissonMap<K, V> extends RedissonExpirable implements RMap<K, V> { ...@@ -1200,6 +1200,10 @@ public class RedissonMap<K, V> extends RedissonExpirable implements RMap<K, V> {
@Override @Override
public RFuture<Void> loadAllAsync(boolean replaceExistingValues, int parallelism) { public RFuture<Void> loadAllAsync(boolean replaceExistingValues, int parallelism) {
if (options.getLoader() == null) {
throw new NullPointerException("MapLoader isn't defined");
}
Iterable<K> keys; Iterable<K> keys;
try { try {
keys = options.getLoader().loadAllKeys(); keys = options.getLoader().loadAllKeys();
...@@ -1217,10 +1221,14 @@ public class RedissonMap<K, V> extends RedissonExpirable implements RMap<K, V> { ...@@ -1217,10 +1221,14 @@ public class RedissonMap<K, V> extends RedissonExpirable implements RMap<K, V> {
@Override @Override
public RFuture<Void> loadAllAsync(Set<? extends K> keys, boolean replaceExistingValues, int parallelism) { public RFuture<Void> loadAllAsync(Set<? extends K> keys, boolean replaceExistingValues, int parallelism) {
return loadAllAsync((Iterable<K>) keys, replaceExistingValues, parallelism, null); return loadAllAsync(keys, replaceExistingValues, parallelism, null);
} }
protected RFuture<Void> loadAllAsync(Iterable<? extends K> keys, boolean replaceExistingValues, int parallelism, Map<K, V> loadedEntires) { protected RFuture<Void> loadAllAsync(Iterable<? extends K> keys, boolean replaceExistingValues, int parallelism, Map<K, V> loadedEntires) {
if (options.getLoader() == null) {
throw new NullPointerException("MapLoader isn't defined");
}
if (parallelism < 1) { if (parallelism < 1) {
throw new IllegalArgumentException("parallelism can't be lower than 1"); throw new IllegalArgumentException("parallelism can't be lower than 1");
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册