From 6efce31eed46774d247b17786ab110bd25daa48b Mon Sep 17 00:00:00 2001
From: zzz <zzz@mail.i2p>
Date: Wed, 21 Oct 2015 13:11:35 +0000
Subject: [PATCH] Increase timer thread priority
---
core/java/src/net/i2p/util/SimpleTimer2.java | 1 +
router/java/src/net/i2p/router/JobQueue.java | 2 +-
router/java/src/net/i2p/router/JobQueueRunner.java | 1 +
3 files changed, 3 insertions(+), 1 deletion(-)
diff --git a/core/java/src/net/i2p/util/SimpleTimer2.java b/core/java/src/net/i2p/util/SimpleTimer2.java
index f2be244051..4cfab3a0a9 100644
--- a/core/java/src/net/i2p/util/SimpleTimer2.java
+++ b/core/java/src/net/i2p/util/SimpleTimer2.java
@@ -118,6 +118,7 @@ public class SimpleTimer2 {
// (new Exception("OWCH! DAMN! Wrong ThreadGroup `" + name +"', `" + rv.getName() + "'")).printStackTrace();
// }
rv.setDaemon(true);
+ rv.setPriority(Thread.NORM_PRIORITY + 1);
return rv;
}
}
diff --git a/router/java/src/net/i2p/router/JobQueue.java b/router/java/src/net/i2p/router/JobQueue.java
index 2641707be5..141f348bf0 100644
--- a/router/java/src/net/i2p/router/JobQueue.java
+++ b/router/java/src/net/i2p/router/JobQueue.java
@@ -341,7 +341,7 @@ public class JobQueue {
public void startup() {
_alive = true;
I2PThread pumperThread = new I2PThread(_pumper, "Job Queue Pumper", true);
- //pumperThread.setPriority(I2PThread.NORM_PRIORITY+1);
+ pumperThread.setPriority(Thread.NORM_PRIORITY + 1);
pumperThread.start();
}
diff --git a/router/java/src/net/i2p/router/JobQueueRunner.java b/router/java/src/net/i2p/router/JobQueueRunner.java
index 9cf23f9987..ecc4cd954a 100644
--- a/router/java/src/net/i2p/router/JobQueueRunner.java
+++ b/router/java/src/net/i2p/router/JobQueueRunner.java
@@ -21,6 +21,7 @@ class JobQueueRunner extends I2PThread {
_id = id;
_keepRunning = true;
_log = _context.logManager().getLog(JobQueueRunner.class);
+ setPriority(NORM_PRIORITY + 1);
// all createRateStat in JobQueue
//_state = 1;
}
--
GitLab