Package com.alibaba.cloud.ai.service.code.impl

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

Constructor	Description
DockerCodePoolExecutorService(CodeExecutorProperties properties)

Method Summary

Modifier and Type	Method	Description
protected String	createNewContainer()
protected CodePoolExecutorService.TaskResponse	execTaskInContainer(CodePoolExecutorService.TaskRequest request, String containerId)
protected void	removeContainer(String containerId)
protected void	shutdownPool()
protected void	stopContainer(String containerId)

Methods inherited from class com.alibaba.cloud.ai.service.code.impl.AbstractCodePoolExecutorService

clearTempDir, createWritableFile, generateContainerName, runTask

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.alibaba.cloud.ai.service.code.CodePoolExecutorService

runTask

Constructor Details

DockerCodePoolExecutorService

public DockerCodePoolExecutorService(CodeExecutorProperties properties)

Method Details

createNewContainer

protected String createNewContainer()
                             throws Exception

Specified by:

createNewContainer in class AbstractCodePoolExecutorService

Throws:

Exception

execTaskInContainer

protected CodePoolExecutorService.TaskResponse execTaskInContainer(CodePoolExecutorService.TaskRequest request,
 String containerId)
                                                            throws Exception

Specified by:

execTaskInContainer in class AbstractCodePoolExecutorService

Throws:

Exception

stopContainer

protected void stopContainer(String containerId)
                      throws Exception

Specified by:

stopContainer in class AbstractCodePoolExecutorService

Throws:

Exception

removeContainer

protected void removeContainer(String containerId)
                        throws Exception

Specified by:

removeContainer in class AbstractCodePoolExecutorService

Throws:

Exception

shutdownPool

protected void shutdownPool()
                     throws Exception

Overrides:

shutdownPool in class AbstractCodePoolExecutorService

Throws:

Exception