Chinaunix首页 | 论坛 | 博客

RWTH的ChinaUnix博客

首页　| 　博文目录　| 　关于我

RWTH0320

  • 博客访问： 104523
  • 博文数量： 41
  • 博客积分： 0
  • 博客等级： 民兵
  • 技术积分： 352
  • 用 户 组： 普通用户
  • 注册时间： 2013-09-23 12:37
文章分类

全部博文（41）

文章存档

2015年（1）

2014年（28）

2013年（12）

我的朋友
最近访客
推荐博文
相关博文
线程问题的实现

分类： Java

2014-08-30 20:40:23

子线程循环10次，接着主线程循环10，接着又回到子线程循环10次，接着再回到主线程又循环10，如此循环50次，请写出程序。
方法1：
    

点击(此处)折叠或打开

  1. package com.wp;

  3. import java.util.concurrent.Executors;
  4. import java.util.concurrent.ExecutorService;
  5. import java.util.concurrent.locks.Lock;
  6. import java.util.concurrent.locks.ReentrantLock;
  7. import java.util.concurrent.locks.Condition;

  9. public class ThreadTest2{
  10. private static Lock lock = new ReentrantLock();
  11. private static Condition subThreadCondition = lock.newCondition();
  12. private static boolean bBhouldSubThread = false;

  14. public static void main(String [] args)
  15. {
  16.    ExecutorService threadPool = Executors.newFixedThreadPool(3);

  18.    threadPool.execute(new Runnable(){
  19.      public void run(){
  20.           for(int i=0;i<50;i++){              
  21.               lock.lock();
  22.               try{
  23.                   if(!bBhouldSubThread)
  24.                       subThreadCondition.await();
  25.                    for(int j=0;j<10;j++){
  26.                        System.out.println(Thread.currentThread().getName()+ ",j=" + j);
  27.                    }
  28.                    bBhouldSubThread= false;
  29.                    subThreadCondition.signal();
  30.               }catch(Exception e){
  31.               }finally{
  32.                   lock.unlock();
  33.               }
  34.           }
  35.      }
  36.                        });
  37.    
  38.                    threadPool.shutdown();
  39.                    for(int i=0;i<50;i++){
  40.                        lock.lock();
  41.                        try{
  42.                            if(bBhouldSubThread)
  43.                                subThreadCondition.await();
  44.                            for(int j=0;j<10;j++){
  45.                                System.out.println(Thread.currentThread().getName()+ ",j=" + j);
  46.                            }
  47.                            bBhouldSubThread= true;
  48.                            subThreadCondition.signal();
  49.                        }catch(Exception e){
  50.                        }finally{
  51.                            lock.unlock();
  52.                        }
  53.                    }
  54.     }
  55. }
方法2：
  

点击(此处)折叠或打开

  1. package com.wp;
  2. public class ThreadTest3 {
  3.     private static boolean bShouldMain=false;
  4.     public static void main(String[]args) {
  5.     // TODO Auto-generated method stub

  7.     new Thread(new Runnable(){
  8.                                 public void run(){
  9.                                     for(int i=0;i<50;i++){
  10.                                         
  11.                                         synchronized(ThreadTest.class){
  12.                                             if(bShouldMain){
  13.                                                 try{
  14.                                                      ThreadTest.class.wait();
  15.                                                     
  16.                                                     }catch(InterruptedException e){
  17.                                                     e.printStackTrace();
  18.                                                 }
  19.                                             }
  20.                                             
  21.                                             for(int j=0;j<10;j++){
  22.                                                 System.out.println(Thread.currentThread().getName()+"i="+ i + ",j=" + j);
  23.                                             }
  24.                                             
  25.                                             bShouldMain= true;
  26.                                             ThreadTest.class.notify();
  27.                                         }
  28.                                         
  29.                                     }
  30.                                 }
  31.                         }
  32.                 ).start();
  33.     
  34.     for(int i=0;i<50;i++){
  35.         
  36.      synchronized (ThreadTest.class){
  37.           if(!bShouldMain){
  38.               try{
  39.                   ThreadTest.class.wait();
  40.               }catch(InterruptedException e){
  41.                   e.printStackTrace();
  42.               }
  43.           }
  44.          
  45.      for(int j=0;j<10;j++){
  46.          System.out.println(Thread.currentThread().getName()+"i=" + i +",j=" + j);
  47.      }
  48.          bShouldMain=false;
  49.          ThreadTest.class.notify();
  50.      }
  51.      }
  52.      }
  53.     }


   


阅读(521) | 评论(0) | 转发(0) |
0

上一篇：简述synchronized和java.util.concurrent.locks.Lock的异同？

下一篇：HashMap 和 HashTable的区别

给主人留下些什么吧！~~
关于我们 | 关于IT168 | 联系方式 | 广告合作 | 法律声明 | 免费注册

Copyright 2001-2010 ChinaUnix.net All Rights Reserved 北京皓辰网域网络信息技术有限公司. 版权所有

感谢所有关心和支持过ChinaUnix的朋友们

16024965号-6