多线程互相唤醒

问答首页 → 移动开发技术

0 0

多线程互相唤醒20

4个线程，1执行结束唤醒2，然后1进入睡眠...4结束唤醒1 如此循环。要求每个线程中的run方法中的代码只执行完整的一次。1分钟循环这4个线程一次。该怎么办

J2ME

2008年7月31日 17:24

yanjiarui
1
0 0 0

2个答案按时间排序按投票排序

0 0

你用线程池多方便啊,可以自己控制.没有用的线程会放到池子中,还可以节省资源

2008年8月11日 23:39

programming
574
0 1 1

添加评论

0 0

创建四个线程，2，3，4线程开始就wait。1运行结束就notify 线程2。
每次运行的时候判断前一次运行时间和这次运行时间的时间差。

import java.util.Date;

/**
 * @author jolestar
 * 
 */
public class ThreadTest {

    /**
     * 
     */
    public ThreadTest() {
    }

    private static class TestThread extends Thread {
	private Thread next;
	//前一次运行时间
	private long preRuntime =0;

	public TestThread(String name, Thread next) {
	    super(name);
	    this.next = next;
	}
	
	public void setNext(Thread next){
	    this.next = next;
	}
	
	@Override
	public void run() {
	    synchronized (this) {
		    try {
			this.wait();
		    } catch (InterruptedException e) {
			e.printStackTrace();
		    }
		}
	    while (true) {
		//前一次运行是否经过了1分钟
		if((System.currentTimeMillis()-this.preRuntime)<60*1000){
		    long time = 60*1000-(System.currentTimeMillis()-this.preRuntime);
		    System.out.println("need to sleep:"+time);
		    try {
			this.sleep(time);
		    } catch (InterruptedException e) {
			e.printStackTrace();
		    }
		}
		
		dosomething();
		synchronized (this.next) {
		    this.next.notify();
		}
		synchronized (this) {
		    try {
			this.wait();
		    } catch (InterruptedException e) {
			e.printStackTrace();
		    }
		}
	    }
	}

	public void dosomething() {
	    Date date = new Date();
	    preRuntime = date.getTime();
	    System.out.println(this.getName() + " do some thing."+date.toString());
	}

    }

    /**
     * @param args
     */
    public static void main(String[] args) {
	TestThread t1 = new TestThread("1",null);
	TestThread t2 = new TestThread("2",null);
	t1.setNext(t2);
	
	TestThread t3 = new TestThread("3",null);
	t2.setNext(t3);
	
	TestThread t4 = new TestThread("4",t1);
	t3.setNext(t4);
	
	t1.start();
	t2.start();
	t3.start();
	t4.start();
	
	System.out.println("notify t1");
	synchronized (t1) {
	    t1.notify();
	}
	
    }

}

2008年8月05日 17:45