class A extends Thread
{
        private String name;
        Demo1(String name)
        {
                this.name = name;
        }
        public void run()
        {
                for(int x=0;x<60;x++)
                    {
                        System.out.println(name+" demo run"+x);
                         //怎么实现同步
                    }
        }
}


public class Test
{
        public static void main(String[] args)
        {
                Demo1 d1 = new Demo1("one");
                Demo1 d2 = new Demo1("two");
                d1.start();
                d2.start();
        }
}

请问下如何实现one线程循环一次后等待two线程执行循环一次,然后再执行one线程?

java循环中执行多线程问题-如何在循环中等待一个线程结束后再自动开始新的线程
遇到一个很头疼的难题.执行一个线程,然后该线程里还有一个时间循环的线程(timertask()).我想让时间循环线程每5分钟循环一次,执行两次后就cancel()掉这个timer.然后再重新调用一个新的timer.我现在把该timer线程放入一个while循环中.但执行以后,循环就会同步执行无限个该timer线程,以至内存溢出出错.   有没有什么方法能让这个while循环启动一次timer以后就暂停,直到该timer线程cancel()掉以后,再自动new一个新的timer线程呢?望大侠们指定.我整理的代码如下.那个线程组的代码可以忽略,就理解成开始一个线程就行.

1. public   class   Test1{
   
2.         public   static   Vector   task_counter_t=new   Vector();   
   
3.         public   static   Vector   task_counter_r=new   Vector();
   
4.         public   static   void   main(String[]   args)   {
   
5.                 task_counter_r.insertElementAt(new   Main1(),1);
   
6.                 task_counter_t.addElement(new   Thread(   (Runnable)task_counter_r.elementAt(1)));       
   
7.               ((Thread)   task_counter_t.elementAt(1)).start();
   
8. }
   
9. }
   
10. 
    
11. 
    
12. class   Main1     implements   Runnable   {
    
13.         
    
14.         public   static   boolean   go1=true;      
    
15.         
    
16.         public   static   int   tim1=1;
    
17.         
    
18.         public   void   run(){
    
19. 
    
20.         final   Timer   timera   =   new   Timer()
    
21. 
    
22.         while(go1){
    
23. 
    
24.                 timera.schedule(new   TimerTask()   {
    
25. 
    
26.                 public   void   run()   {
    
27. 
    
28.                 tim1++;
    
29. 
    
30.                 if(tim1==4){
    
31.                 tim1=1;
    
32.                 timera.cancel();
    
33.                 }
    
34.                 else   {
    
35.                 System.out.printl( "执行一次 ");
    
36.                 }
    
37. 
    
38.                 },   0,5*1000*60
    
39. 
    
40. }
    
41. }

复制代码

1. //卖票系统,每个线程卖一张
   
2. 
   
3. package com.hmm;
   
4. 
   
5. class res1
   
6. {
   
7.         public int num = 100;
   
8.         public boolean flag = true;
   
9. }
   
10. 
    
11. class sale1 implements Runnable
    
12. {
    
13.         private res1 r;
    
14.         sale1(res1 r)
    
15.         {
    
16.                 this.r = r;
    
17.         }
    
18.         public void run()
    
19.         {
    
20.                 while(true)
    
21.                 {
    
22.                         synchronized(r)
    
23.                         {
    
24.                                 if(r.flag)
    
25.                                         System.out.println("sale1 "+ r.num--);
    
26.                                         r.flag = false;
    
27.                                         if(r.num<=0)
    
28.                                                 return;
    
29.                         }
    
30.                 }
    
31.         }
    
32. }
    
33. class sale2 implements Runnable
    
34. {
    
35.         private res1 r;
    
36.         sale2(res1 r)
    
37.         {
    
38.                 this.r = r;
    
39.         }
    
40.         public void run()
    
41.         {
    
42.                 while(true)
    
43.                 {
    
44.                         synchronized(r)
    
45.                         {
    
46.                                 if(r.flag == false)
    
47.                                 {
    
48.                                         System.out.println("sale2 "+ r.num--);
    
49.                                         r.flag = true;
    
50.                                         if(r.num<=0)
    
51.                                                 return;
    
52.                                 }
    
53.                         }
    
54.                 }
    
55.         }
    
56. }
    
57. public class Test2
    
58. {
    
59.        
    
60.         public static void main(String[] args)
    
61.         {
    
62.                 res1 r = new res1();
    
63.                 Thread d1 = new Thread(new sale1(r));
    
64.                 Thread d2 = new Thread(new sale2(r));
    
65.                 d1.start();
    
66.                 d2.start();
    
67.         }
    
68. }

复制代码