Class DockerCodePoolExecutorService
java.lang.Object
com.alibaba.cloud.ai.service.code.impl.AbstractCodePoolExecutorService
com.alibaba.cloud.ai.service.code.impl.DockerCodePoolExecutorService
- All Implemented Interfaces:
CodePoolExecutorService
public class DockerCodePoolExecutorService
extends AbstractCodePoolExecutorService
implements CodePoolExecutorService
运行Python任务的容器池(Docker实现类)
- Since:
- 2025/7/12
- Author:
- vlsmb
-
Nested Class Summary
Nested classes/interfaces inherited from interface com.alibaba.cloud.ai.service.code.CodePoolExecutorService
CodePoolExecutorService.State, CodePoolExecutorService.TaskRequest, CodePoolExecutorService.TaskResponse -
Field Summary
Fields inherited from class com.alibaba.cloud.ai.service.code.impl.AbstractCodePoolExecutorService
consumerThreadPool, coreContainerState, currentCoreContainerSize, currentTempContainerSize, properties, readyCoreContainer, readyTempContainer, taskQueue, tempContainerRemoveFuture, tempContainerState -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected Stringprotected CodePoolExecutorService.TaskResponseexecTaskInContainer(CodePoolExecutorService.TaskRequest request, String containerId) protected voidremoveContainer(String containerId) protected voidprotected voidstopContainer(String containerId) Methods inherited from class com.alibaba.cloud.ai.service.code.impl.AbstractCodePoolExecutorService
clearTempDir, createWritableFile, generateContainerName, runTaskMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface com.alibaba.cloud.ai.service.code.CodePoolExecutorService
runTask
-
Constructor Details
-
DockerCodePoolExecutorService
-
-
Method Details
-
createNewContainer
- Specified by:
createNewContainerin classAbstractCodePoolExecutorService- Throws:
Exception
-
execTaskInContainer
protected CodePoolExecutorService.TaskResponse execTaskInContainer(CodePoolExecutorService.TaskRequest request, String containerId) throws Exception - Specified by:
execTaskInContainerin classAbstractCodePoolExecutorService- Throws:
Exception
-
stopContainer
- Specified by:
stopContainerin classAbstractCodePoolExecutorService- Throws:
Exception
-
removeContainer
- Specified by:
removeContainerin classAbstractCodePoolExecutorService- Throws:
Exception
-
shutdownPool
- Overrides:
shutdownPoolin classAbstractCodePoolExecutorService- Throws:
Exception
-