reafactor: removed background thread to mark storage broken not needed anymore
@@ -217,13 +217,7 @@ public final class OWOWCache extends OAbstractWriteCache
/** Executor which runs in single thread all tasks are related to flush of write cache data. */
private static final ScheduledExecutorService commitExecutor;
- /** Executor which is used to call event listeners in background thread */
- private static final ExecutorService cacheEventsPublisher;
-
static {
- cacheEventsPublisher =
- OThreadPoolExecutors.newCachedThreadPool(
- "OrientDB Write Cache Event Publisher", OStorageAbstract.storageThreadGroup);
commitExecutor =
OThreadPoolExecutors.newSingleThreadScheduledPool(
"OrientDB Write Cache Flush Task", OStorageAbstract.storageThreadGroup);
@@ -567,10 +561,6 @@ public final class OWOWCache extends OAbstractWriteCache
}
private void callPageIsBrokenListeners(final String fileName, final long pageIndex) {
- cacheEventsPublisher.execute(
- new Runnable() {
- @Override
- public void run() {
for (final WeakReference<OPageIsBrokenListener> pageIsBrokenListenerWeakReference :
pageIsBrokenListeners) {
final OPageIsBrokenListener listener = pageIsBrokenListenerWeakReference.get();
@@ -587,8 +577,6 @@ public final class OWOWCache extends OAbstractWriteCache
}
}
}
- });
- }
@Override
public long bookFileId(final String fileName) {
