sclass ActualThoughtSpace extends AbstractThoughtSpace implements AutoCloseable { new TripleIndex index; int limit; // 0 = no limit Map blocked = newWeakHashMap(); Set blockedA, blockedB; *() {} *(int *limit) {} *(AbstractThoughtSpace parent) { super(parent); } public GlobalID postTriple(T3 t, bool verified) { print("Posting: " + t + " / " + verified); if (limitReached()) fail("Thought space limit reached"); TripleWeb w = tripleWeb(t); w.verified(verified); index.addTriple(w); ret w.globalID(); } // existence of triple has already been checked public GlobalID postTriple(T3 t) { if (limitReached()) fail("Thought space limit reached"); TripleWeb w = tripleWeb(t); index.addTriple(w); ret w.globalID(); } bool limitReached() { ret limit > 0 && size() >= limit; } /*public bool hasTriple(Symbol a, Symbol b, Symbol c) { ret index.getExact(a, b, c) != null; }*/ L> get(Symbol s) { ret ai_triplesToTripleRefs_lazyList(s, getTriples(s)); } L> get(Symbol s, int position) { ret ai_triplesToTripleRefs_lazyList(s, getTriples(s, position)); } L getTriples(Symbol s) { L l = parent == null ? null : filterNonBlockedTriples_lazy(parent.getTriples(s)); ret combineLists(l, index.getTriples(ai_shortenForIndex(s))); } L getTriples(Symbol s, int position) { L l = parent == null ? null : filterNonBlockedTriples_lazy(parent.getTriples(s, position)); ret combineLists(l, index.getTriples(ai_shortenForIndex(s), position)); } L getOneTwo(Symbol a, Symbol b) { ret index.getOneTwo(a, b); } L filterNonBlockedTriples_lazy(final L l) { class FilterList extends LazyList { final int n = l(l); public int size() { ret n; } public TripleWeb get(int i) { TripleWeb w = syncGet(l, i); if (w != null && isBlocked(w)) null; ret w; } } ret new FilterList; } L filterNonBlockedTriples(L l) { if (empty(blockedA) && empty(blockedB)) ret l; L out = emptyListWithCapacity(l); for (TripleWeb w : l) if (!isBlocked(w)) out.add(w); ret out; } bool isBlocked(TripleWeb t) { ret contains(blockedA, t.a) || contains(blockedB, t.b); } int size() { ret index.size(); } public void close() { thoughtSpaceDone(this); } Collection allTriples() { ret index.allTriples(); } void setBlockedA(Collection l) { blockedA = asSymbolSet(allToSymbol(l)); } }