| 程序包 | 说明 |
|---|---|
| com.alibaba.schedulerx.worker.container | |
| com.alibaba.schedulerx.worker.pull |
| 限定符和类型 | 类和说明 |
|---|---|
class |
ActorContainer |
class |
DockerContainer |
class |
ProcessContainer |
class |
ThreadContainer |
| 限定符和类型 | 方法和说明 |
|---|---|
static Container |
ContainerFactory.create(JobContext context) |
Container |
ContainerPool.get(String uniqueId) |
| 限定符和类型 | 方法和说明 |
|---|---|
Map<String,Container> |
ContainerPool.getContainerMap() |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
ContainerPool.put(String uniqueId,
Container container) |
void |
ThreadContainerPool.submit(long jobId,
long jobInstanceId,
long taskId,
Container container,
int consumerSize) |
abstract void |
ContainerPool.submit(long jobId,
long jobInstanceId,
long taskId,
Container container,
int consumerSize)
submit task container
|
| 限定符和类型 | 方法和说明 |
|---|---|
void |
ContainerPool.setContainerMap(Map<String,Container> containerMap) |
| 限定符和类型 | 类和说明 |
|---|---|
class |
ConsumerThread |
Copyright © 2021. All rights reserved.