线程循环 - 扩展线程 Class Java

Thread loop - Extending Thread Class Java

我需要编写一个扩展线程的应用程序 class。我的 class 在实例化时接受一个整数(即 100)。 (MyThread myt = new MyThread(100); ) 此整数将是此 class 循环和打印消息的次数。该消息应显示为“线程是 运行…100”。 100 将是我传递给构造函数的任何数字。如果数字是 150,那么输出应该是“The Thread is 运行… 100”。我应该使用 main 方法来测试这个 class。主要是我将启动 2 个线程,一个 150 的线程和一个 200 的线程。我不需要为此代码使用 sleep() 方法。

我已经写了代码,但我很困惑。我的消息应该打印 100 次吗?我不确定我的代码是否满足所有要求。 我还应该实现此代码更改此 class 以使用可运行接口而不是线程 class

public class MyThread extends Thread {

    private int numtimes;

    public MyThread(int numtimes) {
        this.numbtimes = numbtimes;

    }

    public void run() {

        for (int i = 0; i < numbtimes; i++) {
            System.out.println("Thread Running..." + numbtimes);

        }
    }

    public static void main(String[] args) {

        MyThread mytr1 = new MyThread(150);
        mytr1.start();

        MyThread mytr2 = new MyThread(200);
        mytr2.start();
    }

}

这是问的吗?你会如何使用 Runnable 接口?

您可以使用两种方式。其实是同一种。但我更喜欢 lambda

public class WhosebugDemo {

/**
 * one
 * */
public static class MyRun implements Runnable {
    private int numtimes;

    public MyRun(int numtimes) {
        this.numtimes = numtimes;
    }

    @Override
    public void run() {
        for (int i = 0; i < numtimes; i++) {
            System.out.println(String.format("Thread(%s) Running... numtimes(%d), current count (%d) ",
                    Thread.currentThread().getName(),
                    numtimes, i));
        }
    }
}

/**
 * another way
 * */
public static void print(int numtimes) {
    for (int i = 0; i < numtimes; i++) {
        System.out.println(String.format("Thread(%s) Running... numtimes(%d), current count (%d) ",
                Thread.currentThread().getName(),
                numtimes, i));
    }
}

public static void main(String[] args) {
    /**
     * one
     * */
    Thread t1 = new Thread(new MyRun(150), "thread 1");
    Thread t2 = new Thread(new MyRun(200), "thread 2");
    t1.start();
    t2.start();

    /**
     * another way
     * */
    new Thread(() -> WhosebugDemo.print(150), "t1").start();
    new Thread(() -> WhosebugDemo.print(200), "t2").start();
}

}