Alawn/Chronicle-Map
1
0
Fork 0
mirror of https://github.com/OpenHFT/Chronicle-Map.git synced 2021-09-13 01:26:12 +00:00
Code Releases Activity

changed to MapClosable

Browse Source
This commit is contained in:
Rob Austin
2020-05-29 18:22:13 +01:00
parent e129a208f2
commit b51207186a
2 changed files with 6 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/hash/HashSegmentContext.java
+5 -7
View File
@@ -16,7 +16,7 @@
package net.openhft.chronicle.hash;
import net.openhft.chronicle.core.io.DefaultCloseable;
import net.openhft.chronicle.map.MapClosable;
import java.util.function.Consumer;
import java.util.function.Predicate;
@@ -28,7 +28,7 @@ import java.util.function.Predicate;
* @param <E> the entry type
* @see ChronicleHash#segmentContext(int)
*/
public interface HashSegmentContext<K, E extends HashEntry<K>> extends HashContext<K>, DefaultCloseable {
public interface HashSegmentContext<K, E extends HashEntry<K>> extends HashContext<K>, MapClosable {
/**
* Performs the given action for each <i>present</i> entry in this segment until all entries have been processed or the action throws an {@code
@@ -39,16 +39,14 @@ public interface HashSegmentContext<K, E extends HashEntry<K>> extends HashConte
void forEachSegmentEntry(Consumer<? super E> action);
/**
* Checks the given predicate on each <i>present</i> entry in this segment until all entries
* have been processed or the predicate returns {@code false} for some entry, or throws
* an {@code Exception}. Exceptions thrown by the predicate are relayed to the caller.
* Checks the given predicate on each <i>present</i> entry in this segment until all entries have been processed or the predicate returns {@code
* false} for some entry, or throws an {@code Exception}. Exceptions thrown by the predicate are relayed to the caller.
* <p>
* <p>If this segment is empty (i. e. {@link #size()} call returns 0), this method returns
* {@code true} immediately.
*
* @param predicate the predicate to be checked for each entry in this segment
* @return {@code true} if the predicate returned {@code true} for all checked entries,
* {@code false} if it returned {@code false} for some entry
* @return {@code true} if the predicate returned {@code true} for all checked entries, {@code false} if it returned {@code false} for some entry
*/
boolean forEachSegmentEntryWhile(Predicate<? super E> predicate);
src/main/java/net/openhft/chronicle/map/OldDeletedEntriesCleanupThread.java
+1 -2
View File
@@ -16,7 +16,6 @@
package net.openhft.chronicle.map;
import net.openhft.chronicle.core.io.DefaultCloseable;
import net.openhft.chronicle.hash.ChronicleHashBuilderPrivateAPI;
import net.openhft.chronicle.hash.ReplicatedHashSegmentContext;
import net.openhft.chronicle.hash.replication.ReplicableEntry;
@@ -34,7 +33,7 @@ import static net.openhft.chronicle.hash.replication.TimeProvider.currentTime;
import static net.openhft.chronicle.hash.replication.TimeProvider.systemTimeIntervalBetween;
class OldDeletedEntriesCleanupThread extends Thread
implements DefaultCloseable, Predicate<ReplicableEntry> {
implements MapClosable, Predicate<ReplicableEntry> {
private static final Logger LOG = LoggerFactory.getLogger(OldDeletedEntriesCleanupThread.class);
/**