package tech.powerjob.samples.tester;
|
|
import tech.powerjob.worker.core.processor.ProcessResult;
|
import tech.powerjob.worker.core.processor.TaskContext;
|
import tech.powerjob.worker.core.processor.sdk.BasicProcessor;
|
import org.springframework.stereotype.Component;
|
|
/**
|
* 测试用户反馈的无法停止实例的问题 (可中断)
|
* https://github.com/PowerJob/PowerJob/issues/37
|
*
|
* @author tjq
|
* @since 2020/7/30
|
*/
|
@Component
|
@SuppressWarnings("all")
|
public class StopInstanceTester implements BasicProcessor {
|
@Override
|
public ProcessResult process(TaskContext context) throws Exception {
|
int i = 0;
|
while (true) {
|
System.out.println(i++);
|
// interruptable
|
Thread.sleep(10000L);
|
}
|
}
|
}
|
