两个线程不同运行方法并行工作

Question

我想同时运行两个不同运行方法的线程。可能吗？我在下面有简单的代码，但它们不兼容。我只想每5秒运行第一个线程，并且总是运行第二个线程。

public static int x = 0; 

public static void main(String[] args) throws InterruptedException{ 

    Runnable r1 = new Runnable() { 
     public void run() { 
      x = x + 1; 
      System.out.println("increment x"); 
     } 
    }; 

    Runnable r2 = new Runnable() { 
     public void run() { 
      System.out.println("x is "+x); 
     } 
    }; 

    while(true){ 
     Thread t1 = new Thread(r1); 
     Thread t2 = new Thread(r2); 
     t1.start(); 
     t2.start(); 
     t1.sleep(5000); 
    } 
} 

Answer 1

public class Test { 
public static int x = 0; 

public static void main(String[] args) throws InterruptedException{ 

    Runnable r1 = new Runnable() { 
     public void run() { 
      while(true){ 
      x = x + 1; 
      System.out.println("increment x"); 
      try { 
       Thread.sleep(5000); 
      } catch (InterruptedException e) { 
       // TODO Auto-generated catch block 
       e.printStackTrace(); 
      } 
      } 
     } 
    }; 

    Runnable r2 = new Runnable() { 
     public void run() { 
      while(true){ 
      System.out.println("x is "+x); 
      } 
     } 
    }; 
     Thread t1 = new Thread(r1); 
     Thread t2 = new Thread(r2); 
     t1.start(); 
     t2.start(); 

//的Thread.sleep （5000）;

} 

}

是这样的..但保持在上述

Answer 2

您的run()方法只增加x，打印它并返回。只要run方法返回，线程就会停止运行。如果您想要永远运行某些东西，则需要在run()方法中使用循环。而且，在没有任何同步的情况下访问共享变量将不会导致可预测的结果。你的x变量应该至少是易变的。最后，Thread.sleep（）是一个静态方法。因此，应使用类名叫做：

Thread.sleep(5000L); 

它使当前线程睡眠。

下面是一个例子，其中一个线程增量X每500毫秒时间，一个其他线程打印X每100毫秒时间，并且两个线程都在5秒钟后中断：

public class ThreadExample { 
    private static volatile int x; 

    private static class Incrementer implements Runnable { 
     @Override 
     public void run() { 
      while (!Thread.currentThread().isInterrupted()) { 
       x++; 
       try { 
        Thread.sleep(500L); 
       } 
       catch (InterruptedException e) { 
        return; 
       } 
      } 
     } 
    } 

    private static class Reader implements Runnable { 
     @Override 
     public void run() { 
      while (!Thread.currentThread().isInterrupted()) { 
       System.out.println(x); 
       try { 
        Thread.sleep(100L); 
       } 
       catch (InterruptedException e) { 
        return; 
       } 
      } 
     } 
    } 

    public static void main(String[] args) throws InterruptedException { 
     Thread t1 = new Thread(new Incrementer()); 
     Thread t2 = new Thread(new Reader()); 
     t1.start(); 
     t2.start(); 

     try { 
      Thread.sleep(5000L); 
     } 
     finally { 
      t1.interrupt(); 
      t2.interrupt(); 
     } 
    } 
} 

Answer 3

在while循环做心灵点，你每次创建新Threads然后start他们每个人说的就是为什么你有这样行为。

然后，你将需要移动while循环线程内，使他们LOOL象下面这样：

public static volatile int x = 0; 

public static void main(String[] args) throws InterruptedException{ 

Runnable r1 = new Runnable() { 
    public void run() { 
     while (true) { 
     x = x + 1; 
     System.out.println("increment x"); 
     this.sleep(5000); 
     } 
    } 
}; 

Runnable r2 = new Runnable() { 
    public void run() { 
     while(true){ 
     System.out.println("x is "+x); 
     } 
    } 
}; 
Thread t1 = new Thread(r1); 
Thread t2 = new Thread(r2); 
t1.start(); 
t2.start(); 
} 

还请注意，您的x变量应该同步存取看到正确的值。

BR。

Answer 4

Thread t1;; 
    Thread t2; 
while(true){ 
     t1 = new Thread(r1); 
     t2= new Thread(r2); 
     t1.start(); 
     t1.sleep(5000); 
     t2.start(); 

} 

你正在添加的代码是正确的把代码放在t2.sleep（5000）t2.start（）之前。