黑马程序员技术交流社区

标题: 如何实现线程同步? [打印本页]
作者: hhmm665544    时间: 2014-3-3 13:16
标题: 如何实现线程同步?
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线程?

作者: itpower    时间: 2014-3-3 13:23
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. }


  12. class   Main1     implements   Runnable   {
  13.         
  14.         public   static   boolean   go1=true;      
  15.         
  16.         public   static   int   tim1=1;
  17.         
  18.         public   void   run(){

  20.         final   Timer   timera   =   new   Timer()

  22.         while(go1){

  24.                 timera.schedule(new   TimerTask()   {

  26.                 public   void   run()   {

  28.                 tim1++;

  30.                 if(tim1==4){
  31.                 tim1=1;
  32.                 timera.cancel();
  33.                 }
  34.                 else   {
  35.                 System.out.printl( "执行一次 ");
  36.                 }

  38.                 },   0,5*1000*60

  40. }
  41. }
复制代码
作者: hhmm665544    时间: 2014-3-4 14:08
  1. //卖票系统,每个线程卖一张

  3. package com.hmm;

  5. class res1
  6. {
  7.         public int num = 100;
  8.         public boolean flag = true;
  9. }

  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. }
复制代码




欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2