菲律宾申博代理开户合作

并发工具类——Semaphore

本文来源:http://www.sg535.com/www_58che_com/

菲律宾申博代理开户合作,近日,该平台新增了从1984年到2016年之间的地球图像和数据。“每辆车涨价至少一万多块钱…12月06日07:22  刚刚发布的2016款15英寸搭载了最高分辨率2880×1800的显示屏,但有用户近来发现,这款素质超高的屏幕并没有被充分利用,因为系统默认分辨率竟然只有1680×1050。执行部网络广告技术支持1名岗位职责:1.投放网站常规广告;2.手动上传富媒体广告;3.优化广告效果。

多种功能的自定义选择能为您提供更个性化的浏览体验。人工智能的出现,能够将新闻从业者从简单、重复性的工作中解放出来。有人用俄罗斯的一套人脸识别系统,在高峰时间段,总共有1400余人通过了机器的检测,而人类检票员通道通过了将近2000人。大数据分析停滞不前信任问题面临大考Forrester研究公司在2016年7月发起了一份调查报告,针对KPMG(毕马威会计事务所)管理的2165位数据和分析决策制造商进行调查。

同时,针对…12月05日20:46文/刘鹏腾讯财经从保监会了解到,近日保监会下发监管函,针对万能险业务经营存在问题,并且整改不到位的前海人寿采取停止开展万能险新业务的监管措施;同时,针对前海人寿…12月05日19:5112月5日,上海证券交易所微信公众号“上交所发布”发布了一则名为“股市西游记之盘中涨跌幅限制价格虚假申报篇”的视频,讲述了一个典型的盘中以账户限制价格虚假申报,…12月05日18:19文/刘鹏证监会主席刘士余上周末关于杠杆收购的言论持续发酵。声明显示,这起推迟协议由中欧体育方面提出,并已经获得了费宁韦斯特董事会的批准。各个角度都能呈现,各个角度都能折射,果然够炫,而这也被魅族官方称为魅蓝系列迄今为止最大胆的设计。分类:大小:93.8MB下载:McAfeeStinger是一个独立的工具,用来检测和清除特殊的病毒。

本博客系列是学习并发编程过程中的记录总结。由于文章比较多,写的时间也比较散,所以我整理了个目录贴(传送门),方便查阅。

并发编程系列博客传送门


Semaphore([' sem?f :(r)])的主要作用是控制线程并发的数量。我们可以将Semaphore想象成景区的一个门卫,这个门卫负责发放景区入园的许可证。

景区为了游客的入园观赏体验,决定最多允许200个有个同时在园内观赏。那么这个门卫在每天开园的时候手中都会有200张许可证,每当一个游客要入园的时候门卫会给游客发放一张许可证,当门卫手中的许可证发完之后再有游客需要入园的话就必须等待。

当游客观赏完毕之后,出园的时候需要将许可证交还到门卫手上。门卫将这些交还的许可证再发等待的游客,这些游客就能顺利入园了。

Semaphore的API简介

Semaphore的API使用起来也比较简单,常见的API简介如下:

  • Semaphore(int permits):构造方法,创建具有给定许可数的计数信号量并设置为非公平信号量。
  • Semaphore(int permits,boolean fair):构造方法,当fair等于true时,创建具有给定许可数的计数信号量并设置为公平信号量。
  • void acquire():从此信号量获取一个许可前线程将一直阻塞。相当于一辆车占了一个车位。
  • void acquire(int n):从此信号量获取给定数目许可,在提供这些许可前一直将线程阻塞。比如n=2,就相当于一辆车占了两个车位。
  • boolean tryAcquire(int permits, long timeout, TimeUnit unit):尝试获取,在给定的时间内没获取到资源超时
  • void release():释放一个许可,将其返回给信号量。就如同车开走返回一个车位。
  • void release(int n):释放n个许可。
  • int?availablePermits():当前可用的许可数。

Semaphore的常见用法

下面给出一个Oracle官方文档中的列子代码:

class Pool {
    /可同时访问资源的最大线程数
    private static final int MAX_AVAILABLE = 100; 
    private final Semaphore available = new Semaphore(MAX_AVAILABLE, true);
    /共享资源
    protected Object[] items = new Object[MAX_AVAILABLE];   
    protected boolean[] used = new boolean[MAX_AVAILABLE];
    public Object getItem() throws InterruptedException {
        available.acquire();
        return getNextAvailableItem();
    }
    public void putItem(Object x) {
        if (markAsUnused(x))
            available.release();
    }
    private synchronized Object getNextAvailableItem() {
        for (int i = 0; i < MAX_AVAILABLE; ++i) {
            if (!used[i]) {
                used[i] = true;
                return items[i];
            }
        }
        return null;
    }
    private synchronized boolean markAsUnused(Object item) {
        for (int i = 0; i < MAX_AVAILABLE; ++i) {
            if (item == items[i]) {
                if (used[i]) {
                    used[i] = false;
                    return true;
                } else
                    return false;
            }
        }
        return false;
    }
}

items数组可以看成是我们的共享资源,当有线程尝试使用共享资源时,我们要求线程先获得“许可”(调用Semaphoreacquire方法),这样线程就拥有了权限,否则就需要等待。当使用完资源后,线程需要调用Semaphorerelease方法释放许可。

Semaphore并不能替代synchronized

有些书中提到:如果将Semaphore的许可证数量设置成1的话,就能实现synchronized的功能。其实这种说法是不对的。

下面使用Semaphore来控制对一个账户进行并发存钱和取钱的动作,如果Semaphore能实现synchronized的功能的话,账户最后的余额应该还是10000,但代码执行后的结果并不是这样。大家可以执行下面的代码看下结果。

public static final int THREAD_COUNT = 100;

    public static void main(String[] args) {
        BankAccount myAccount = new BankAccount("accountOfMG", 10000.00);
        for (int i = 0; i < THREAD_COUNT; i++) {
            new Thread(new Runnable() {
                @Override
                public void run() {
                    try {
                        int var = new Random().nextInt(100);
                        Thread.sleep(var);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    double deposit = myAccount.deposit(1000.00);
                    System.out.println(Thread.currentThread().getName() + " balance1:" + deposit);
                }
            }).start();
        }
        for (int i = 0; i < THREAD_COUNT; i++) {
            new Thread(new Runnable() {
                @Override
                public void run() {
                    try {
                        int var = new Random().nextInt(100);
                        Thread.sleep(var);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    double deposit = myAccount.withdraw(1000.00);
                    System.out.println(Thread.currentThread().getName() + " balance2:" + deposit);

                }
            }).start();
        }
    }

    private static class BankAccount {

        Semaphore semaphore = new Semaphore(1);

        String accountName;
        double balance;

        public BankAccount(String accountName, double balance) {
                this.accountName = accountName;
                this.balance = balance;
        }

        public double deposit(double amount) {
            try {
                semaphore.acquire();
                balance = balance + amount;
                return balance;
            } catch (Exception e) {
                throw new RuntimeException("中断...");
            } finally {
                semaphore.release();
            }
        }

        public double withdraw(double amount) {
            try {
                semaphore.acquire();
            balance = balance - amount;
            return balance;
            } catch (Exception e) {
                throw new RuntimeException("中断...");
            } finally {
                semaphore.release();
            }
        }

    }

这里Semaphore并不能实现synchronized的功能的原因是:Semaphore并不能保证共享变量的可见性。

实现原理

Semaphore底层原理还是基于AQS机制的。这边就不具体分析了,感兴趣的可以参考我前面关于菲律宾申博代理开户合作AQS的文章

简单总结

  • Semaphore只能用来做线程同步——控制线程的执行顺序,但是并不能保证线程安全;
  • Semaphore主要用来控制线程的并发数量,通常用在限流组件中。
  • Semaphore基于AQS机制实现。
申博手机客户端下载 申博娱乐太阳成登入 申博怎么开户 申博手机客户端下载 申博太阳城亚洲微信支付充值 申博手机版下载网址
www.sun838.com 菲律宾申博游戏直营网 申博手机客户端下载 金太阳国际娱乐网址 菲律宾太阳娱乐官网登入 菲律宾太阳网a99.com
太阳城娱乐138申博直营网 申博游戏下载登入 申博微信支付充值 申博注册登入 申博游戏端下载 www.msc11.com