Updated
This commit is contained in:
parent
020df10a36
commit
7e9588a9e5
@ -21,7 +21,7 @@ class EncodeDaemon(val referenceId: String, val work: EncodeWork, val daemonInte
|
|||||||
val progress = decoder.parseVideoProgress(items)
|
val progress = decoder.parseVideoProgress(items)
|
||||||
if (progress != null) {
|
if (progress != null) {
|
||||||
daemonInterface.onProgress(referenceId, work, progress)
|
daemonInterface.onProgress(referenceId, work, progress)
|
||||||
//outputCache.clear()
|
outputCache.clear()
|
||||||
}
|
}
|
||||||
} catch (e: Exception) {
|
} catch (e: Exception) {
|
||||||
//logger.error { e.message }
|
//logger.error { e.message }
|
||||||
|
|||||||
@ -25,15 +25,7 @@ class RunnerCoordinator {
|
|||||||
|
|
||||||
val producer = DefaultProducer(CommonConfig.kafkaTopic)
|
val producer = DefaultProducer(CommonConfig.kafkaTopic)
|
||||||
|
|
||||||
val encodeExecutor: ExecutorService = ThreadPoolExecutor(
|
val executor: ExecutorService = ThreadPoolExecutor(
|
||||||
EncodeEnv.maxRunners,
|
|
||||||
EncodeEnv.maxRunners,
|
|
||||||
0L,
|
|
||||||
TimeUnit.MILLISECONDS,
|
|
||||||
LinkedBlockingQueue()
|
|
||||||
)
|
|
||||||
|
|
||||||
val extractExecutor: ExecutorService = ThreadPoolExecutor(
|
|
||||||
EncodeEnv.maxRunners,
|
EncodeEnv.maxRunners,
|
||||||
EncodeEnv.maxRunners,
|
EncodeEnv.maxRunners,
|
||||||
0L,
|
0L,
|
||||||
@ -42,7 +34,7 @@ class RunnerCoordinator {
|
|||||||
)
|
)
|
||||||
|
|
||||||
fun addEncodeMessageToQueue(message: Message) {
|
fun addEncodeMessageToQueue(message: Message) {
|
||||||
encodeExecutor.execute {
|
executor.execute {
|
||||||
try {
|
try {
|
||||||
runBlocking {
|
runBlocking {
|
||||||
if (message.data != null && message.data is EncodeWork) {
|
if (message.data != null && message.data is EncodeWork) {
|
||||||
@ -64,7 +56,7 @@ class RunnerCoordinator {
|
|||||||
}
|
}
|
||||||
|
|
||||||
fun addExtractMessageToQueue(message: Message) {
|
fun addExtractMessageToQueue(message: Message) {
|
||||||
extractExecutor.execute {
|
executor.execute {
|
||||||
runBlocking {
|
runBlocking {
|
||||||
try {
|
try {
|
||||||
if (message.data != null && message.data is ExtractWork) {
|
if (message.data != null && message.data is ExtractWork) {
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user