mirror of
https://github.com/yacy/yacy_search_server.git
synced 2024-09-21 00:00:13 +02:00
ce1adf9955
high-performance search query situations as seen in yacy-metager integration showed deadlock situation caused by synchronization effects inside of sun.java code. It appears that the logger is not completely safe against deadlock situations in concurrent calls of the logger. One possible solution would be a outside-synchronization with 'synchronized' statements, but that would further apply blocking on all high-efficient methods that call the logger. It is much better to do a non-blocking hand-over of logging lines and work off log entries with a concurrent log writer. This also disconnects IO operations from logging, which can also cause IO operation when a log is written to a file. This commit not only moves the logger from kelondro to yacy.logging, it also inserts the concurrency methods to realize non-blocking logging. git-svn-id: https://svn.berlios.de/svnroot/repos/yacy/trunk@6078 6c8d7289-2bf4-0310-a012-ef5d649a1542
97 lines
3.8 KiB
Java
97 lines
3.8 KiB
Java
// serverAbstractBlockingThread.java
|
|
// (C) 2008 by Michael Peter Christen; mc@yacy.net, Frankfurt a. M., Germany
|
|
// first published 27.03.2008 on http://yacy.net
|
|
//
|
|
// $LastChangedDate: 2006-04-02 22:40:07 +0200 (So, 02 Apr 2006) $
|
|
// $LastChangedRevision: 1986 $
|
|
// $LastChangedBy: orbiter $
|
|
//
|
|
// LICENSE
|
|
//
|
|
// This program is free software; you can redistribute it and/or modify
|
|
// it under the terms of the GNU General Public License as published by
|
|
// the Free Software Foundation; either version 2 of the License, or
|
|
// (at your option) any later version.
|
|
//
|
|
// This program is distributed in the hope that it will be useful,
|
|
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
// GNU General Public License for more details.
|
|
//
|
|
// You should have received a copy of the GNU General Public License
|
|
// along with this program; if not, write to the Free Software
|
|
// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
|
|
|
|
package de.anomic.server;
|
|
|
|
import de.anomic.kelondro.util.MemoryControl;
|
|
import de.anomic.yacy.logging.Log;
|
|
|
|
public abstract class serverAbstractBlockingThread<J extends serverProcessorJob> extends serverAbstractThread implements serverBlockingThread<J> {
|
|
|
|
private serverProcessor<J> manager = null;
|
|
|
|
public void setManager(final serverProcessor<J> manager) {
|
|
this.manager = manager;
|
|
}
|
|
public serverProcessor<J> getManager() {
|
|
return this.manager;
|
|
}
|
|
|
|
public void run() {
|
|
this.open();
|
|
if (log != null) {
|
|
logSystem("thread '" + this.getName() + "' deployed, starting loop.");
|
|
}
|
|
long timestamp;
|
|
long memstamp0, memstamp1;
|
|
long busyCycles = 0;
|
|
|
|
while (running) {
|
|
try {
|
|
// do job
|
|
timestamp = System.currentTimeMillis();
|
|
memstamp0 = MemoryControl.used();
|
|
final J in = this.manager.take();
|
|
if ((in == null) || (in == serverProcessorJob.poisonPill) || (in.status == serverProcessorJob.STATUS_POISON)) {
|
|
// the poison pill: shutdown
|
|
// a null element is pushed to the queue on purpose to signal
|
|
// that a termination should be made
|
|
//this.manager.enQueueNext((J) serverProcessorJob.poisonPill); // pass on the pill
|
|
this.running = false;
|
|
break;
|
|
}
|
|
final J out = this.job(in);
|
|
if (out != null) this.manager.passOn(out);
|
|
// do memory and busy/idle-count/time monitoring
|
|
memstamp1 = MemoryControl.used();
|
|
if (memstamp1 >= memstamp0) {
|
|
// no GC in between. this is not shure but most probable
|
|
memuse += memstamp1 - memstamp0;
|
|
} else {
|
|
// GC was obviously in between. Add an average as simple heuristic
|
|
if (busyCycles > 0) memuse += memuse / busyCycles;
|
|
}
|
|
busytime += System.currentTimeMillis() - timestamp;
|
|
} catch (final InterruptedException e) {
|
|
// don't ignore this: shut down
|
|
this.running = false;
|
|
break;
|
|
} catch (final Exception e) {
|
|
// handle exceptions: thread must not die on any unexpected exceptions
|
|
// if the exception is too bad it should call terminate()
|
|
this.jobExceptionHandler(e);
|
|
} finally {
|
|
busyCycles++;
|
|
}
|
|
}
|
|
this.close();
|
|
logSystem("thread '" + this.getName() + "' terminated.");
|
|
}
|
|
|
|
private void logSystem(final String text) {
|
|
if (log == null) Log.logConfig("THREAD-CONTROL", text);
|
|
else log.logConfig(text);
|
|
}
|
|
}
|