专栏首页麒思妙想用阻塞队列,再系一次鞋带

用阻塞队列,再系一次鞋带

题干,是这样的,通过2个线程,交替输出 A1B2C3....Z26dafei1288

在上篇文章里,通过锁打印资源实现了需求,但是总觉着这个代码不够优雅,然后搞了一个阻塞队列的方式,至少代码上,感觉优雅了很多。

import java.util.concurrent.LinkedTransferQueue;
public class TwoThreadQueue {
    public static final int SETPS = 26;
    public static void main(String[] args) {
        LinkedTransferQueue<String> tq = new LinkedTransferQueue<>();
        new Thread(()->{
            int startCharCount = 65;
            for (int i = 0; i < SETPS; i++) {
                try {
                    tq.transfer((char) startCharCount+++"");
                    System.out.println(Thread.currentThread().getName() + " " +tq.take());
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        },"str").start();
        new Thread(()->{
            int startCharCount = 1;
            for (int i = 0; i < SETPS; i++) {
                try {
                    System.out.println(Thread.currentThread().getName() + " " +tq.take());
                    tq.transfer(startCharCount+++"");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        },"num").start();
        System.out.println(tq.size());
    }
}

大体的执行流程,如下图所示,字符串线程将A交给队列,然后进入阻塞状态,数字线程获取内容并进行打印,然后将1交给队列,再进入阻塞状态,字符串线程被叫起,拿走1打印,再将B交给队列,以此类推。

LinkedTransferQueue 的类图如下

LinkedTransferQueue 该类实现了一个 TransferQueue。该接口定义了几个方法:

public interface TransferQueue<E> extends BlockingQueue<E> {
    // 如果可能,立即将元素转移给等待的消费者。
    // 更确切地说,如果存在消费者已经等待接收它(在 take 或 timed poll(long,TimeUnit)poll)中,则立即传送指定的元素,否则返回 false。
    boolean tryTransfer(E e);
    // 将元素转移给消费者,如果需要的话等待。
    // 更准确地说,如果存在一个消费者已经等待接收它(在 take 或timed poll(long,TimeUnit)poll)中,则立即传送指定的元素,否则等待直到元素由消费者接收。
    void transfer(E e) throws InterruptedException;
    // 上面方法的基础上设置超时时间
    boolean tryTransfer(E e, long timeout, TimeUnit unit) throws InterruptedException;
    // 如果至少有一位消费者在等待,则返回 true
    boolean hasWaitingConsumer();
    // 返回等待消费者人数的估计值
    int getWaitingConsumerCount();
}

参考链接:https://www.cnblogs.com/stateis0/p/9062076.html

本文分享自微信公众号 - 麒思妙想(qicai1612),作者:dafei1288

原文出处及转载信息见文内详细说明,如有侵权,请联系 yunjia_community@tencent.com 删除。

原始发表时间:2020-08-10

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 基于REST的数据处理流程v0.1

    一直很欣赏pandas对数据的理解,以及其灵活优雅的数据处理方式。一直在考虑是否可以做一套基于REST的API来进行数据处理。今天突然灵感来了,画了一下...

    麒思妙想
  • 国查:用中文编写SQL

    这两天被 文言(wenyan-lang)刷屏了,这个项目在于使用文言文进行编程,我打算蹭个热度,把年初的作品再捞一捞,即中文SQL。

    麒思妙想
  • Prometheus入门

    Prometheus(普罗米修斯)这款开源监控工具,名字和功能一样酷,本文是一个干货入门,动手来部署一个实验环境。用Prometheus+Grafana来监控M...

    麒思妙想
  • 并发编程之读写锁

    一、读写锁 ReadWriteLock 读写锁维护了一对相关的锁,一个用于只读操作,一个用于写入操作。只要没有writer,读取锁可以由多个reader线程同...

    lyb-geek
  • 设置DHCP中的缺省域名,支持Windows域环境下的特定DNS后缀

    当我们在域环境下ipconfig后显示在Connection-Specific DNS Suffix的域名非常重要,本地访问服务器或电脑名的时候,就会有线读取此...

    崔文远TroyCui
  • Prim算法-最小生成树

    基本思想: 1 置S={1} 2 只要S是V的真子集就做如下的贪心选择:   选取满足条件的i ,i属于S,j输入V-S,且c[i][j]最小的边,并将定点j加...

    用户1154259
  • hdu1033

    @坤的
  • Spark系列课程-00xxSpark RDD持久化

    我们这节课讲一下RDD的持久化 ? RDD的持久化 这段代码我们上午已经看过了,有瑕疵大家看出来了吗? 有什么瑕疵啊? 大家是否还记得我在第二节课的时候跟大...

    Albert陈凯
  • id,hash 和 hashlib

    看了标题,大家应该知道今天我要讲的内容了,其中 id 和 hash 是内置的两个函数,hashlib 是一个模块,它们的共同点就是给每一个对象一个特定的标志,当...

    不可言诉的深渊
  • Gym 100952A&&2015 HIAST Collegiate Programming Contest A. Who is the winner?【字符串,暴力】

    A. Who is the winner? time limit per test:1 second memory limit per test:64 mega...

    Angel_Kitty

扫码关注云+社区

领取腾讯云代金券