首页 / JAVA / JAVA信号量使用示例程序

JAVA信号量使用示例程序

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了JAVA信号量使用示例程序，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1594字，纯文字阅读大概需要3分钟。

内容图文

JAVA里也有强大的信号量工具Semaphore，使用信号量可以很方便的实现线程同步功能，以解决类似于 生产者——消费者 之类的典型问题。

下面是我的测试程序，大部分看注释就可以明白用法：

 

            import
             java.util.LinkedList;

            import
             java.util.Queue;

            import
             java.util.concurrent.Semaphore;



            public
            class
             TestSemaphore {

    
            /**
            
     * 测试主程序
     
            */
            public
            static
            void
             main(String[] args) {
        TestSemaphore t = new TestSemaphore();
        t.runTest();
    }

    //TestSemaphore/**信号量*/private Semaphore mSem = new Semaphore(0);
    /**产生的产品队列*/private Queue<String> mQueue = new LinkedList<String>();
    
    /**
     * 进行测试
     */publicvoid runTest() {
        Runnable runProvider = new Runnable() {
            @Override
            publicvoid run() {
                provider();
            }
        };
        
        Runnable runCustomer = new Runnable() {
            @Override
            publicvoid run() {
                customer();
            }
        };
        
        new Thread(runCustomer).start();
        new Thread(runProvider).start();
        
        while(true) {
            try {
                Thread.sleep(300);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
    
    /**
     * 生产者线程
     */publicvoid provider() {
        for(int i = 0; i < 10; i++) {

            //生成一个产品，放到队列里
            String p = String.format("product_%d", i);
            mQueue.offer(p);
            System.out.println(String.format("Send sig >>>>>>>>>>>>> %s", p));
            
            //发出信号量            mSem.release();
            
            try {
                Thread.sleep(300);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
    
    /**
     * 消费者线程
     */publicvoid customer() {
        while(true) {
            //等待信号量try {
                mSem.acquire();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            
            //从队列里取出一个产品
            String s = mQueue.poll();
            System.out.println(String.format("Get sig : %s", s));
            
            try {
                Thread.sleep(500);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
    
}

 

原文：http://www.cnblogs.com/alexcai/p/4171284.html

内容总结

以上是互联网集市为您收集整理的JAVA信号量使用示例程序全部内容，希望文章能够帮你解决JAVA信号量使用示例程序所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1216045.html

来源：【匿名】