线程不同时运行

Question

我创建了一个并发类来测试线程。因为我想找出同时运行线程的最佳方式。

我对我的结果感到惊讶：

test
test
Othertest
test
Othertest
test
test
test 

我预期的结果是线程随机返回，但它们似乎始终以相同的顺序返回！有谁知道为什么？这是否意味着它们没有同时运行？我怎样才能让它们同时运行？

这是我的代码：

public class ThreadTest {
    public static void main(String args[]) throws InterruptedException
    {
        new Thread(new ThreadTest().test()).start();
        new Thread(new ThreadTest().test()).start();
        new Thread(new ThreadTest().otherTest()).start();
        new Thread(new ThreadTest().test()).start();
        new Thread(new ThreadTest().otherTest()).start();
        new Thread(new ThreadTest().test()).start();
        new Thread(new ThreadTest().test()).start();
        new Thread(new ThreadTest().test()).start();
    }

    public  Runnable test() throws InterruptedException{
        Thread.sleep((long) (Math.random()*1000));
        System.out.println("test");
        return null;
    }

    public  Runnable otherTest() throws InterruptedException{
        Thread.sleep((long) (Math.random()*1000));
        System.out.println("Othertest");
        return null;
    }

}

Answer 1

Thread 构造函数接受Runnable，Thread 最终将在其上执行run() 方法。现在你没有返回 Runnable 对象。你正在返回null。因此，您在 test() 和 otherTest() 方法中执行的操作是同步执行的。

您的所有执行都发生在一个线程中。这个

new Thread(new ThreadTest().test()).start();

执行test()，休眠一秒钟，打印"test"并返回null。 start() 调用没有任何作用，因为 Runnable 是 null。对于您所做的每个其他呼叫，这种情况都会继续。

您需要将 test() 和 otherTest() 方法中的所有内容放在 Runnable#run() 方法中。例如

new Thread(new Runnable() {
    public void run() {
         Thread.sleep((long) (Math.random()*1000));
         System.out.println("test");
    }
}).start();

考虑Thread类的run()方法的源码，在调用start()时执行

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

其中target 是您在构造函数中传递的Runnable 引用。显然，如果是null，它什么也做不了。

Answer 2

我认为您可能会因此获得更好的运气：

public class ThreadTest {
public static void main(String args[]) throws InterruptedException
{
    new Thread(test).start();
    new Thread(test).start();
    new Thread(otherTest).start();
    new Thread(test).start();
    new Thread(otherTest).start();
    new Thread(test).start();
    new Thread(test).start();
    new Thread(test).start();
}

public static Runnable test = new Runnable() {
    @Override
    public void run()  {
        try {
            Thread.sleep((long) (Math.random()*1000));
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        System.out.println("test");
    }
};

public static Runnable otherTest = new Runnable() {
    @Override
    public void run(){
        try {
            Thread.sleep((long) (Math.random()*1000));
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        System.out.println("Othertest");
    }
};

}

这个想法是将Runnable 的实例作为参数传递给Thread 构造函数。你并没有真正这样做，因为test() 和otherTest() 都返回null。上面的代码显示了一种以我猜你想要的方式运行线程的方法。其他方法当然是可能的。

Answer 3

您需要将test 和otherTest 方法实现为Runnable 实现。像这样：

private static class Test implements Runnable {
    @Override
    public void run() {
        try {
            Thread.sleep((long) (Math.random()*1000));
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            return;
        }
        System.out.println("test");
    }
}

private static class OtherTest implements Runnable {
    @Override
    public void run() {
        try {
            Thread.sleep((long) (Math.random()*1000));
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            return;
        }
        System.out.println("Othertest");
    }
}

public static void main(String args[]) {
    new Thread(new Test()).start();
    new Thread(new Test()).start();
    new Thread(new OtherTest()).start();
    new Thread(new Test()).start();
    new Thread(new OtherTest()).start();
    new Thread(new Test()).start();
    new Thread(new Test()).start();
    new Thread(new Test()).start();
}

当然，您可以尝试减少一点重复：

private enum Runnables implements Runnable {
    TEST {
        @Override
        public void run() {
            if (!sleep()) return;
            System.out.println("test");
        }
    },
    OTHER_TEST {
        @Override
        public void run() {
            if (!sleep()) return;
            System.out.println("Othertest");
        }
    };

    static boolean sleep() {
        try {
            Thread.sleep((long) (Math.random()*1000));
            return true;
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            return false;
        }
    }
}

public static void main(String args[]) {
    new Thread(Runnables.TEST).start();
    new Thread(Runnables.TEST).start();
    new Thread(Runnables.OTHER_TEST).start();
    new Thread(Runnables.TEST).start();
    new Thread(Runnables.OTHER_TEST).start();
    new Thread(Runnables.TEST).start();
    new Thread(Runnables.TEST).start();
    new Thread(Runnables.TEST).start();
}

Answer 4

您的Thread 实现是错误。

您应该实现 Runnable 并实现 run() 方法或 您应该扩展 Thread 类并覆盖 run() 方法。

正在发生的事情是您的 test() 方法或 otherTest() 正在被调用，就像任何方法调用一样。而且由于您没有任何 run() 方法，因此您的 Thread.start() 不会简单地运行任何东西。

尝试改变你的方法，如下所示。

public Runnable test() {
    return new Runnable() {
        @Override
        public void run() {
            try {
                Thread.sleep((long) (Math.random() * 1000));
                System.out.println("test");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    };
}


public Runnable otherTest() {
    System.out.println("Othertest");
    return new Runnable() {

        @Override
        public void run() {
            try {
                Thread.sleep((long) (Math.random() * 1000));
                    System.out.println("Othertest");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    };
}