From 734680dc700ffb2fd9333051595f13dbc2cb034b Mon Sep 17 00:00:00 2001 From: lotus Date: Thu, 21 May 2009 08:30:34 +0000 Subject: [PATCH] initialize the ResourceObsever in own thread git-svn-id: https://svn.berlios.de/svnroot/repos/yacy/trunk@5968 6c8d7289-2bf4-0310-a012-ef5d649a1542 --- source/de/anomic/crawler/ResourceObserver.java | 11 ++++++++++- source/de/anomic/plasma/plasmaSwitchboard.java | 4 +--- 2 files changed, 11 insertions(+), 4 deletions(-) diff --git a/source/de/anomic/crawler/ResourceObserver.java b/source/de/anomic/crawler/ResourceObserver.java index d47b82c88..72bff2426 100644 --- a/source/de/anomic/crawler/ResourceObserver.java +++ b/source/de/anomic/crawler/ResourceObserver.java @@ -31,6 +31,7 @@ import java.util.Map; import de.anomic.kelondro.util.Log; import de.anomic.plasma.plasmaSwitchboard; import de.anomic.plasma.plasmaSwitchboardConstants; +import de.anomic.server.serverInstantBusyThread; import de.anomic.tools.diskUsage; public final class ResourceObserver { @@ -47,7 +48,7 @@ public final class ResourceObserver { private static final int MEDIUM = 1; private static final int HIGH = 2; - private static final Log log = new Log("RESOURCE OBSERVER"); + public static final Log log = new Log("RESOURCE OBSERVER"); private final plasmaSwitchboard sb; private int checkDiskUsageCount; @@ -90,6 +91,14 @@ public final class ResourceObserver { checkMemoryUsageCount = 0; disksFree = HIGH; memoryFree = HIGH; + } + + public static void initThread() { + plasmaSwitchboard sb = plasmaSwitchboard.getSwitchboard(); + // initializing the resourceObserver + sb.observer = new ResourceObserver(sb); + // run the oberver here a first time + sb.observer.resourceObserverJob(); } /** diff --git a/source/de/anomic/plasma/plasmaSwitchboard.java b/source/de/anomic/plasma/plasmaSwitchboard.java index 8c9421fdc..5c624478a 100644 --- a/source/de/anomic/plasma/plasmaSwitchboard.java +++ b/source/de/anomic/plasma/plasmaSwitchboard.java @@ -576,9 +576,7 @@ public final class plasmaSwitchboard extends serverAbstractSwitch