X-Git-Url: https://de.git.xonotic.org/?p=xonotic%2Fxonotic.git;a=blobdiff_plain;f=misc%2Ftools%2FNexuizDemoRecorder%2Fmain%2Fsrc%2Fmain%2Fjava%2Fcom%2Fnexuiz%2Fdemorecorder%2Fapplication%2FRecorderJobPoolExecutor.java;h=949eef5cd58a4c8774a952b573fe1f73e34136fd;hp=7f4181f68aa6acb8af94593c29efccebb5d41f97;hb=5f46e908547dffbaba1661966633ec2eea4c6940;hpb=e5832bf2ecac60a672a29c85cd8dec341a215e1c diff --git a/misc/tools/NexuizDemoRecorder/main/src/main/java/com/nexuiz/demorecorder/application/RecorderJobPoolExecutor.java b/misc/tools/NexuizDemoRecorder/main/src/main/java/com/nexuiz/demorecorder/application/RecorderJobPoolExecutor.java index 7f4181f6..949eef5c 100644 --- a/misc/tools/NexuizDemoRecorder/main/src/main/java/com/nexuiz/demorecorder/application/RecorderJobPoolExecutor.java +++ b/misc/tools/NexuizDemoRecorder/main/src/main/java/com/nexuiz/demorecorder/application/RecorderJobPoolExecutor.java @@ -1,48 +1,48 @@ -package com.nexuiz.demorecorder.application; - - -import java.util.ArrayList; -import java.util.List; -import java.util.concurrent.ArrayBlockingQueue; -import java.util.concurrent.ThreadPoolExecutor; -import java.util.concurrent.TimeUnit; - -import com.nexuiz.demorecorder.application.jobs.RecordJob; - -public class RecorderJobPoolExecutor { - - private int poolSize = 1; - private int maxPoolSize = 1; - private long keepAliveTime = 10; - private ThreadPoolExecutor threadPool = null; - private ArrayBlockingQueue queue = null; - - public RecorderJobPoolExecutor() { - queue = new ArrayBlockingQueue(99999); - threadPool = new ThreadPoolExecutor(poolSize, maxPoolSize, keepAliveTime, TimeUnit.SECONDS, queue); - } - - public void runJob(Runnable task) { - threadPool.execute(task); - } - - public void clearUnfinishedJobs() { - threadPool.getQueue().clear(); - } - - public void shutDown() { - threadPool.shutdownNow(); - } - - public synchronized List getJobList() { - List list = new ArrayList(); - for (Runnable job : this.queue) { - try { - RecordJob j = (RecordJob)job; - list.add(j); - } catch (ClassCastException e) {} - } - - return list; - } -} +package com.nexuiz.demorecorder.application; + + +import java.util.ArrayList; +import java.util.List; +import java.util.concurrent.ArrayBlockingQueue; +import java.util.concurrent.ThreadPoolExecutor; +import java.util.concurrent.TimeUnit; + +import com.nexuiz.demorecorder.application.jobs.RecordJob; + +public class RecorderJobPoolExecutor { + + private int poolSize = 1; + private int maxPoolSize = 1; + private long keepAliveTime = 10; + private ThreadPoolExecutor threadPool = null; + private ArrayBlockingQueue queue = null; + + public RecorderJobPoolExecutor() { + queue = new ArrayBlockingQueue(99999); + threadPool = new ThreadPoolExecutor(poolSize, maxPoolSize, keepAliveTime, TimeUnit.SECONDS, queue); + } + + public void runJob(Runnable task) { + threadPool.execute(task); + } + + public void clearUnfinishedJobs() { + threadPool.getQueue().clear(); + } + + public void shutDown() { + threadPool.shutdownNow(); + } + + public synchronized List getJobList() { + List list = new ArrayList(); + for (Runnable job : this.queue) { + try { + RecordJob j = (RecordJob)job; + list.add(j); + } catch (ClassCastException e) {} + } + + return list; + } +}