Expose Thread owner() in ChainingInterface

This commit is contained in:
leventov
2016-07-17 23:25:46 +07:00
parent a230c08e89
commit b3c1f7b1e2
4 changed files with 6 additions and 4 deletions
@@ -23,7 +23,7 @@ import java.util.List;
import java.util.function.Function;
@Staged
public class Chaining extends ChainingInterface {
public abstract class Chaining extends ChainingInterface {
public final List<ChainingInterface> contextChain;
public final int indexInContextChain;
@@ -16,6 +16,8 @@
package net.openhft.chronicle.hash.impl.stage.hash;
public class ThreadLocalState {
public abstract class ThreadLocalState {
public boolean iterationContextLockedInThisThread;
public abstract Thread owner();
}
@@ -26,7 +26,7 @@ import net.openhft.chronicle.set.ChronicleSet;
import net.openhft.sg.Staged;
@Staged
public class ReplicatedChronicleMapHolderImpl<K, V, R> extends Chaining
public abstract class ReplicatedChronicleMapHolderImpl<K, V, R> extends Chaining
implements ReplicatedChronicleMapHolder<K, V, R> {
private final ReplicatedChronicleMap<K, V, R> m;
@@ -26,7 +26,7 @@ import net.openhft.chronicle.set.ChronicleSet;
import net.openhft.sg.Staged;
@Staged
public class VanillaChronicleMapHolderImpl<K, V, R> extends Chaining
public abstract class VanillaChronicleMapHolderImpl<K, V, R> extends Chaining
implements VanillaChronicleMapHolder<K, V, R> {
private final VanillaChronicleMap<K, V, R> m;