I2P Address: [http://git.idk.i2p]

Skip to content
Snippets Groups Projects
Commit 6efce31e authored by zzz's avatar zzz
Browse files

Increase timer thread priority

parent f713a197
No related branches found
No related tags found
No related merge requests found
...@@ -118,6 +118,7 @@ public class SimpleTimer2 { ...@@ -118,6 +118,7 @@ public class SimpleTimer2 {
// (new Exception("OWCH! DAMN! Wrong ThreadGroup `" + name +"', `" + rv.getName() + "'")).printStackTrace(); // (new Exception("OWCH! DAMN! Wrong ThreadGroup `" + name +"', `" + rv.getName() + "'")).printStackTrace();
// } // }
rv.setDaemon(true); rv.setDaemon(true);
rv.setPriority(Thread.NORM_PRIORITY + 1);
return rv; return rv;
} }
} }
......
...@@ -341,7 +341,7 @@ public class JobQueue { ...@@ -341,7 +341,7 @@ public class JobQueue {
public void startup() { public void startup() {
_alive = true; _alive = true;
I2PThread pumperThread = new I2PThread(_pumper, "Job Queue Pumper", true); I2PThread pumperThread = new I2PThread(_pumper, "Job Queue Pumper", true);
//pumperThread.setPriority(I2PThread.NORM_PRIORITY+1); pumperThread.setPriority(Thread.NORM_PRIORITY + 1);
pumperThread.start(); pumperThread.start();
} }
......
...@@ -21,6 +21,7 @@ class JobQueueRunner extends I2PThread { ...@@ -21,6 +21,7 @@ class JobQueueRunner extends I2PThread {
_id = id; _id = id;
_keepRunning = true; _keepRunning = true;
_log = _context.logManager().getLog(JobQueueRunner.class); _log = _context.logManager().getLog(JobQueueRunner.class);
setPriority(NORM_PRIORITY + 1);
// all createRateStat in JobQueue // all createRateStat in JobQueue
//_state = 1; //_state = 1;
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment