如何让传入ResourceConsumerThread的Runnable实例引用该线程对象？

你的需求核心是让传入的lambda能直接拿到当前ResourceConsumerThread实例——标准Runnable做不到这一点，因为它的run()方法没有参数，没法把当前线程对象传递进去。我们可以通过自定义一个带参数的函数式接口来优雅解决这个问题，具体步骤如下：

1. 定义线程感知的函数式接口 #

先创建一个专门的函数式接口，让它的run方法接收当前的ResourceConsumerThread实例作为参数：

@FunctionalInterface
public interface ThreadAwareRunnable {
    void run(ResourceConsumerThread thread);
}

这个接口只包含一个抽象方法，符合函数式接口的要求，完全可以用lambda来实现。

2. 修改ResourceConsumerThread类 #

调整你的线程类，让它接收这个自定义接口的实例，然后在run()方法里调用接口的run()时传入this（也就是当前线程对象）：

public class ResourceConsumerThread extends Thread {
    private final ThreadAwareRunnable threadAwareRunnable;

    // 构造方法接收自定义的函数式接口
    public ResourceConsumerThread(ThreadAwareRunnable threadAwareRunnable) {
        this.threadAwareRunnable = threadAwareRunnable;
    }

    @Override
    public void run() {
        // 调用自定义接口的方法，把当前线程对象传进去
        threadAwareRunnable.run(this);
    }
}

3. 使用方式 #

现在创建线程实例时，lambda就能直接拿到当前的ResourceConsumerThread对象了，你可以在lambda里任意调用这个线程的方法或访问属性，轻松实现不同线程的差异化行为：

public class Main {
    public static void main(String[] args) {
        // 第一个线程：打印线程基本信息
        ResourceConsumerThread thread1 = new ResourceConsumerThread(thread -> {
            System.out.println("线程ID: " + thread.getId() + " 正在执行任务");
            System.out.println("线程名称: " + thread.getName());
        });

        // 第二个线程：模拟资源处理逻辑
        ResourceConsumerThread thread2 = new ResourceConsumerThread(thread -> {
            System.out.println("线程 " + thread.getName() + " 开始处理资源");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                thread.interrupt();
            }
            System.out.println("线程 " + thread.getName() + " 资源处理完成");
        });

        thread1.start();
        thread2.start();
    }
}

为什么这个方案更优？ #

• 逻辑清晰：自定义接口明确要求传入当前线程对象，lambda编写时直接拿到实例，不需要额外捕获或引用外部变量。
• 安全可靠：线程run()方法传入的this保证lambda拿到的就是当前正在运行的ResourceConsumerThread实例，不会出现引用错误。
• 符合需求：多个线程实例可通过不同lambda实现完全不同的行为，同时能无缝访问对应线程的对象。

备选方案：先创建线程再绑定Runnable #

如果你不想自定义接口，也可以先创建线程实例，再给它设置一个捕获了该线程实例的Runnable，但这种方式需要注意必须在线程启动前设置Runnable：

public class ResourceConsumerThread extends Thread {
    private Runnable customRunnable;

    public void setCustomRunnable(Runnable customRunnable) {
        this.customRunnable = customRunnable;
    }

    @Override
    public void run() {
        if (customRunnable != null) {
            customRunnable.run();
        }
    }
}

// 使用示例
public class Main {
    public static void main(String[] args) {
        ResourceConsumerThread thread = new ResourceConsumerThread();
        // lambda捕获thread变量，注意thread必须是effectively final（这里满足，之后未重新赋值）
        thread.setCustomRunnable(() -> {
            System.out.println("使用线程实例: " + thread.getId());
        });
        thread.start();
    }
}

不过这个方案的缺点是线程初始化和行为设置分离，容易出现线程已启动但未设置Runnable的错误，不如第一种方案安全直观。

内容的提问来源于stack exchange，提问作者DevdattaK