怎么加入一个判定条件，根据当前线程的的名字，来做出动作。

Question

public class ThreadTest3 {
public static void main(String[] args) throws InterruptedException {
String s = "xingxing";
MyThread mt = new MyThread();
Thread t = new Thread(mt);
t.setName(s);
t.start();

for(int i = 0;i < 20; i++){
System.out.println("我是主线程。i:  " + i + " " + Thread.currentThread());
Thread.sleep(1000);
if(i == 10 && Thread.currentThread() == t){
System.out.println("\n 醒工砖\n ");
mt.call();}
}
}
}class MyThread implements Runnable{
Thread th1; public void run() {
for(int i = 0;i < 10;i++){
System.out.println("我是二线程。i:  " + i + " " + Thread.currentThread());
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
if(i == 5 && Thread.currentThread() == ){  // 这里我想加上一个判定条件，当前线程为二线程的时候，执行wait();
wat();
}
}

} public void call(){
notifyAll();
}

public void wat(){
try {
wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}

}

Answer 1

我想加上一个判定条件，当前线程为二线程的时候，并且 i == 5了，执行wait方法。这条语句该怎么写呢？主方法我给线程命名了，但是不能用？

Answer 2

楼上的，这样写么？if(i == 5 && Thread.currentThread() == Thread.currentThread().getName())
貌似不能编译啊。

Answer 3

if(i == 5 && Thread.currentThread() == Thread.currentThread().getName().equals("xingxing"))

Answer 4

if(i == 5 && "xingxing".equals(Thread.currentThread().getName()))

Answer 5

好像wait和notify函数只能配合synchronized关键字一起使用的jdk的文档里面也写到要执行wait和notify，当前线程必须拥有对象监视器，我估计对象监视器就是指synchronized吧
public class ThreadTest3 {    
    public static void main(String[] args) throws InterruptedException {
        String s = "xingxing";
        MyThread mt = new MyThread();
        Thread t = new Thread(mt);
        t.setName(s);
        t.start();                        
        
        for(int i = 0;i < 20; i++){
            System.out.println("我是主线程。i:  " + i + " " + Thread.currentThread());
            Thread.sleep(1000);
            if(i == 10 /*&& Thread.currentThread() == t*/){
                System.out.println("\n 醒工砖\n ");
                mt.call();}
        }
    }
    }class MyThread implements Runnable{
    Thread th1;    public void run() {
        for(int i = 0;i < 10;i++){
            System.out.println("我是二线程。i:  " + i + " " + Thread.currentThread());
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            if(i == 5 /*&& Thread.currentThread().getName().equals("xingxing")*/){  // 这里我想加上一个判定条件，当前线程为二线程的时候，执行wait();
                wat();
            }
        }
        
    }        public void call(){
     synchronized(this)
     {
     notifyAll();
     }
    }
    
    public void wat(){
        try {
         synchronized(this)
         {
         wait();
         }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    
    }

Answer 6

synchronized 的的使用我知道。现在我就是不想使用synchronized，加入判定线程的代码，这样可以么？

Answer 7

其实根据当前的线程的名字来做出相应动作，应该是不行的Thread.currentThread()返回的是当前执行的线程的引用主线程运行到这句返回结果永远都是主线程的引用二线程运行到这句返回结果永远都是二线程的引用所以这句加不加都没什么意义因为wait和notify必须和synchronized一起使用，如果你不想用synchronized，那么可以尝试用信号量
import java.util.concurrent.*;public class ThreadTest3 {    
    public static void main(String[] args) throws InterruptedException {
        String s = "xingxing";
        MyThread mt = new MyThread();
        Thread t = new Thread(mt);
        t.setName(s);
        t.start();                        
        
        for(int i = 0;i < 20; i++){
            System.out.println("我是主线程。i:  " + i + " " + Thread.currentThread());
            Thread.sleep(1000);
            if(i == 10 /*&& Thread.currentThread() == t*/){
                System.out.println("\n 醒工砖\n ");
                mt.call();}
        }
    }
    }class MyThread implements Runnable{
    private Semaphore semaphore = new Semaphore(0); //初值为0
    
    public void run() {
        for(int i = 0;i < 10;i++){
            System.out.println("我是二线程。i:  " + i + " " + Thread.currentThread());
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            if(i == 5 /*&& Thread.currentThread().getName().equals("xingxing")*/){  // 这里我想加上一个判定条件，当前线程为二线程的时候，执行wait();
                wat();
            }
        }
        
    }        public void call(){
     /*synchronized(this)
     {
     notifyAll();
     }*/
     semaphore.release(); //semaphore+1，如果大于等于0，线程运行
    }
    
    public void wat(){
        try {
         /*synchronized(this)
         {
         wait();
         }*/
         semaphore.acquire(); //semaphore-1，如果小于0，线程挂起
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
    
    }

Answer 8

public class ThreadTest3 {    
    public static void main(String[] args) throws InterruptedException {
        String s = "xingxing";
        MyThread mt = new MyThread();
        Thread t = new Thread(mt);
        t.setName(s);
        t.start();                        
        
        for(int i = 0;i < 20; i++){
            System.out.println("我是主线程。i:  " + i + " " + Thread.currentThread());
            Thread.sleep(1000);
            if(i==10){//你原来的目的是想在主线程执行到第十次的时候把那个线程唤醒是吧？
             mt.send(10);
            }
            /*if(i == 10){
                System.out.println("\n 醒工砖\n ");
                
                mt.call();
                }*/
        }
    }
    }class MyThread implements Runnable{
    Thread th1;
    int m;
    public void run() {
        for(int i = 0;i < 10;i++){
            System.out.println("我是二线程。i:  " + i + " " + Thread.currentThread());
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }            
            if(i == 5 ){  // “这里我想加上一个判定条件，当前线程为二线程的时候，执行wait();”这里你用到的Thread.currentThread()得到只能是当前线程也就是为你所说的二线程。所以这里不需要这个判断。               wai();
                
            }
            
        }
        
    }        public synchronized void call(){//要锁定
        notifyAll();
    }
    public synchronized void wai(){//同样要锁定
      try
{
this.wait();
} catch (InterruptedException e)
{
e.printStackTrace();
}
    }
    public void send(int m){
     this.m=m;
     if(m==10){
     call();
     }
    }
    }
我把你的想法理解成上述程序。