derryh/ujetl
1
0
Fork 0
mirror of https://github.com/rasilon/ujetl.git synced 2026-04-11 10:29:29 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Give the threads useful names.

Browse source
This commit is contained in:
Derry Hamilton 2019-05-16 08:31:17 +01:00
parent 6ba081b625
commit e8d49669b1
1 changed files with 3 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

3
src/main/java/com/rasilon/ujetl/Job.java
View file

@ -50,6 +50,7 @@ public class Job extends Thread {
resultBuffer = new ArrayBlockingQueue<List<String>>( 3 * blockSize); resultBuffer = new ArrayBlockingQueue<List<String>>( 3 * blockSize);
producerLive = new AtomicBoolean(true); producerLive = new AtomicBoolean(true);
this.setName(String.format("%s-%s-Manager",jobName,name));
} }
int arraySum(int[] arr) { int arraySum(int[] arr) {
@ -69,6 +70,7 @@ public class Job extends Thread {
public Producer(ResultSet src,BlockingQueue q) { public Producer(ResultSet src,BlockingQueue q) {
this.src = src; this.src = src;
this.q = q; this.q = q;
this.setName(String.format("%s-%s-Consumer",jobName,name));
} }
public void run() { public void run() {
try { try {
@ -114,6 +116,7 @@ public class Job extends Thread {
public Consumer(PreparedStatement insertStatement,BlockingQueue q) { public Consumer(PreparedStatement insertStatement,BlockingQueue q) {
this.insertStatement = insertStatement; this.insertStatement = insertStatement;
this.q = q; this.q = q;
this.setName(String.format("%s-%s-Consumer",jobName,name));
} }
public void run() { public void run() {
try { try {