zoukankan      html  css  js  c++  java
  • 线程的协作

     
     
     
    class Printer extends Thread
    {
        Vector task = new Vector();
        boolean runing = false;
        public void start()
        {
            runing = true;
            super.start();
        }
        public void run()
        {
            try
            {
                System.out.println("打印开始");
                while (runing)
                {
                    synchronized (this)
                    {
                        while ((task.size() == 0) && runing)
                        {
                            // 如果任务列表为空,而且线程还允许运行,则等待任务
                            System.out.println("没有什么内容可以打印了,等待中~~~~");
                            wait();
                            System.out.println("等待结束,准备打印内容");
                        }
                    }
                    if (runing)
                    {
                        //for(int i=0;i<task.size();i++)
                        System.out.println("任务是: " + task.lastElement());
                        task.remove(0);
                    }
                }
                System.out.println("打印结束");
            } catch (Exception e)
            {
                // TODO: handle exception
                e.printStackTrace();
            }
        }
     
        // 添加待打印的任务
        public void addTask(String s)
        {
            synchronized (this)
            {
                this.task.add(s);
                //this.task.add(s);
                //this.task.add(s);
                System.out.println("有内容可以打印了  唤醒打印线程");
                notify();
                // notifyAll();
            }
     
        }
     
        public void stopPrinter()
        {
            this.runing = false;
            synchronized (this)
            {
                System.out.println("停止打印线程 ");
                notify();
                // noitfyAll();
            }
        }
     
    }
     
    public class WaitNotify
    {
        public static void main(String[] args)
        {
            Printer printer = new Printer();
            printer.start();
            try
            {
                Thread.sleep(2000);
                for (int i = 0; i < 500; i++)
                {
                    Thread.sleep(1000);
                    printer.addTask("打印的i的结果是" + i);
                }
            } catch (InterruptedException e)
            {
                // TODO: handle exception
                e.printStackTrace();
            }
     
            printer.stopPrinter();
     
        }
    }
     
    梦里不知身是客,一晌贪欢。
  • 相关阅读:
    js模拟点击加载事件代码
    js添加节点
    js数字随机产生并相加
    转:Selenium借助AutoIt识别上传(下载)详解
    [原创] web_custom_request 与 Viewstate
    转:浏览器与WEB服务器工作过程举例
    转:WebDriver(Selenium2) 处理可能存在的JS弹出框
    转:Loadrunner报错“Too many local variablesAction.c”解决方法
    转:loadrunner关联及web_reg_save_param方法浅析
    转:性能测试流程剖析
  • 原文地址:https://www.cnblogs.com/dccmmtop/p/5710156.html
Copyright © 2011-2022 走看看