Java线程池 - Callable和Runnable封装

• 对Callable和Runnable封装，提供自定义执行接口

• 补充异常处理

Runnable

@Slf4j
public class CustomRunnable implements Runnable {

    private Runnable runnable;

    public CustomRunnable() {

    }

    public CustomRunnable(final Runnable runnable) {
        this.runnable = runnable;
    }

    private String taskId;

    public void setTaskId(String taskId) {
        this.taskId = taskId;
    }

    @Override
    public void run() {
        if (runnable == null) {
            return;
        }

        try {
            runnable.run();
        } catch (Exception e) {
            log.error("任务:{},错误栈:{}", taskId, e);
            e.printStackTrace();
        }

    }

    @Override
    public String toString() {
        return Thread.currentThread().getName();
    }
}

Callable

@Slf4j
public class CustomCallable<T> implements Callable {

    Callable<T> callable;

    public CustomCallable(Callable<T> callable) {
        this.callable = callable;
    }

    private String taskId;

    public void setTaskId(String taskId) {
        this.taskId = taskId;
    }
    
    @Override
    public T call() throws Exception {
        if (callable == null) {
            return null;
        }

        try {
            return callable.call();
        } catch (Exception e) {
            log.error("任务:{},错误栈:{}", taskId, e);
            e.printStackTrace();
        }
        return null;
    }

    @Override
    public String toString() {
        return Thread.currentThread().getName();
    }
}

区别

模块	Runnable	Callable
返回值	否	是
返回对象	无	Future
执行方法	run	call
执行超时	无	get(long timeout,TimeUtil unit)
获取结果	无	get、isDone
异常处理	无	throws Exception
线程阻塞	否	是,LockSupport.park