AICon上海|与字节、阿里、腾讯等企业共同探索Agent 时代的落地应用 了解详情
写点什么

那些有用但不为大家所熟知的 Java 特性

  • 2022-02-07
  • 本文字数:3965 字

    阅读完需:约 13 分钟

那些有用但不为大家所熟知的 Java 特性

本文最初发表于 Piotr Mińkowski 的个人站点 Medium 网站,经作者授权,由 InfoQ 中文站翻译分享。


在本文中,你将会了解到一些有用的 Java 特性,这些特性可能你之前没有听说过。这是我最近在阅读关于 Java 的文章时,才发现和整理的私人特性清单。我不会把重点放到语言方面,而是会放到 API 方面。


你喜欢 Java,想了解它最新的特性吗?如果是的话,你可以阅读我关于 Java 8 之后新特性的文章。接下来,在本文中你将会了解到八个不为大家熟知但是非常有用的特性。那我们开始吧!

延迟队列


我们都知道,在 Java 中有类型众多的集合。那么你听说过 DelayQueue 吗?它是一个特殊类型的 Java 集合,允许我们根据元素的延迟时间对其进行排序。坦白来讲,这是一个非常有意思的类。尽管 DelayQueue 类是 Java 集合的成员之一,但是它位于 java.util.concurrent 包中。它实现了 BlockingQueue 接口。只有当元素的时间过期时,才能从队列中取出。


要使用这个集合,首先,我们的类需要实现 Delayed 接口的 getDelay 方法。当然,它不一定必须是类,也可以是 Java Record。


public record DelayedEvent(long startTime, String msg) implements Delayed {
public long getDelay(TimeUnit unit) { long diff = startTime - System.currentTimeMillis(); return unit.convert(diff, TimeUnit.MILLISECONDS); }
public int compareTo(Delayed o) { return (int) (this.startTime - ((DelayedEvent) o).startTime); }
}
复制代码


假设我们想要把元素延迟 10 秒钟,那么我们只需要在 DelayedEvent 类上将时间设置成当前时间加上 10 秒钟即可。


final DelayQueue<DelayedEvent> delayQueue = new DelayQueue<>();final long timeFirst = System.currentTimeMillis() + 10000;delayQueue.offer(new DelayedEvent(timeFirst, "1"));log.info("Done");log.info(delayQueue.take().msg());
复制代码


对于上面的代码,我们能够看到什么输出呢?如下所示。


时间格式中支持显示一天中的时段


好吧,我承认这个 Java 特性对于你们中的大多数人来讲并没有太大的用处,但是,我对这个特性情有独钟……Java 8 对时间处理 API 做了很多的改进。从这个版本的 Java 开始,在大多数情况下,我们都不需要任何额外的库来处理时间了,比如 Joda Time。你可能想象不到,从 Java 16 开始,我们甚至可以使用标准的格式化器来表达一天中的时段,也就是“in the morning”或者“in the afternoon”。这是一个新的格式模式,叫做 B。


String s = DateTimeFormatter  .ofPattern("B")  .format(LocalDateTime.now());System.out.println(s);
复制代码


如下是我运行的结果。当然,你的结果可能会因时间不同而有所差异。



好,稍等……现在,你可能会问这个格式为什么叫做 B。事实上,对于这种类型的格式来讲,它不是最直观的名字。但也许下面的表格能够解决我们所有的疑惑。它是 DateTimeFormatter 能够处理的模式字符和符号的片段。我猜想,B 是第一个空闲出来的字母。当然,我可能是错的。


StampedLock


我认为,Java Concurrent 是最有趣的 Java 包之一。同时,它也是一个不太为开发者所熟知的包,当开发人员主要使用 web 框架的时候更是如此。我们有多少人曾经在 Java 中使用过锁呢?锁是一种比 synchronized 块更灵活的线程同步机制。从 Java 8 开始,我们可以使用一种叫做 StampedLock 的新锁。StampedLock 是 ReadWriteLock 的一个替代方案。它允许对读操作进行乐观的锁定。而且,它的性能比 ReentrantReadWriteLock 更好。


假设我们有两个线程。第一个线程更新一个余额,而第二个线程则读取余额的当前值。为了更新余额,我们当然需要先读取其当前值。在这里,我们需要某种同步机制,假设第一个线程在同一时间内多次运行。第二个线程阐述了如何使用乐观锁来进行读取操作。


StampedLock lock = new StampedLock();Balance b = new Balance(10000);Runnable w = () -> {   long stamp = lock.writeLock();   b.setAmount(b.getAmount() + 1000);   System.out.println("Write: " + b.getAmount());   lock.unlockWrite(stamp);};Runnable r = () -> {   long stamp = lock.tryOptimisticRead();   if (!lock.validate(stamp)) {      stamp = lock.readLock();      try {         System.out.println("Read: " + b.getAmount());      } finally {         lock.unlockRead(stamp);      }   } else {      System.out.println("Optimistic read fails");   }};
复制代码


现在,我们同时运行这两个线程 50 次。它的结果应该是符合预期的,最终的余额是 60000。


ExecutorService executor = Executors.newFixedThreadPool(10);for (int i = 0; i < 50; i++) {   executor.submit(w);   executor.submit(r);}
复制代码

并发累加器


在 Java Concurrent 包中,有意思的并不仅仅有锁,另外一个很有意思的东西是并发累加器(concurrent accumulator)。我们也有并发的加法器(concurrent adder),但它们的功能非常类似。LongAccumulator(我们也有 DoubleAccumulator)会使用一个提供给它的函数更新一个值。在很多场景下,它能让我们实现无锁的算法。当多个线程更新一个共同的值的时候,它通常会比 AtomicLong 更合适。


我们看一下它是如何运行的。要创建它,我们需要在构造函数中设置两个参数。第一个参数是一个用于计算累加结果的函数。通常情况下,我们会使用 sum 方法。第二个参数表示累积器的初始值。


现在,让我们创建一个初始值为 10000 的 LongAccumulator,然后从多个线程调用 accumulate() 方法。最后的结果是什么呢?如果你回想一下的话,我们做的事情和上一节完全一样,但这一次没有任何锁。



LongAccumulator balance = new LongAccumulator(Long::sum, 10000L);Runnable w = () -> balance.accumulate(1000L);
ExecutorService executor = Executors.newFixedThreadPool(50);for (int i = 0; i < 50; i++) { executor.submit(w);}
executor.shutdown();if (executor.awaitTermination(1000L, TimeUnit.MILLISECONDS)) System.out.println("Balance: " + balance.get());assert balance.get() == 60000L;
复制代码

十六进制格式


关于这个特性并没有什么大的故事。有时我们需要在十六进制的字符串、字节或字符之间进行转换。从 Java 17 开始,我们可以使用 HexFormat 类实现这一点。只要创建一个 HexFormat 的实例,然后就可以将输入的 byte 数组等格式化为十六进制字符串。你还可以将输入的十六进制字符串解析为字节数组,如下所示。


HexFormat format = HexFormat.of();
byte[] input = new byte[] {127, 0, -50, 105};String hex = format.formatHex(input);System.out.println(hex);
byte[] output = format.parseHex(hex);assert Arrays.compare(input, output) == 0;
复制代码

数组的二分查找


假设我们想在排序的数组中插入一个新的元素。如果数组中已经包含该元素的话,Arrays.binarySearch() 会返回该搜索键的索引,否则,它返回一个插入点,我们可以用它来计算新键的索引:-(insertion point)-1。此外,在 Java 中,binarySearch 方法是在一个有序数组中查找元素的最简单和最有效的方法。


让我们考虑下面的例子。我们有一个输入的数组,其中有四个元素,按升序排列。我们想在这个数组中插入数字 3,下面的代码展示了如何计算插入点的索引。



int[] t = new int[] {1, 2, 4, 5};int x = Arrays.binarySearch(t, 3);
assert ~x == 2;
复制代码

Bit Set


如果我们需要对 bit 数组进行一些操作该怎么办呢?你是不是会使用 boolean[] 来实现呢?其实,有一种更有效、更节省内存的方法来实现。这就是 BitSet 类。BitSet 类允许我们存储和操作 bit 的数组。与 boolean[] 相比,它消耗的内存要少 8 倍。我们可以对数组进行逻辑操作,例如:and、or、xor。


比方说,有两个 bit 的数组, 我们想对它们执行 xor 操作。为了做到这一点,我们需要创建两个 BitSet 的实例,并在实例中插入样例元素,如下所示。最后,对其中一个 BitSet 实例调用 xor 方法,并将第二个 BitSet 实例作为参数。


BitSet bs1 = new BitSet();bs1.set(0);bs1.set(2);bs1.set(4);System.out.println("bs1 : " + bs1);
BitSet bs2 = new BitSet();bs2.set(1);bs2.set(2);bs2.set(3);System.out.println("bs2 : " + bs2);
bs2.xor(bs1);System.out.println("xor: " + bs2);
复制代码


如下是运行上述代码的结果:


Phaser


最后,我们介绍本文最后一个有趣的 Java 特性。和其他一些样例一样,它也是 Java Concurrent 包的元素,被称为 Phaser。它与更知名的 CountDownLatch 相当相似。然而,它提供了一些额外的功能。它允许我们设置在继续执行之前需要等待的线程的动态数量。在 Phaser 中,已定义数量的线程需要在进入下一步执行之前在屏障上等待。得益于此,我们可以协调多个阶段的执行。


在下面的例子中,我们设置了一个具有 50 个线程的屏障,在进入下一个执行阶段之前,需要到达该屏障。然后,我们创建一个线程,在 Phaser 实例上调用 arriveAndAwaitAdvance() 方法。它会一直阻塞线程,直到所有的 50 个线程都到达屏障。然后,它进入 phase-1,同样会再次调用 arriveAndAwaitAdvance() 方法。


Phaser phaser = new Phaser(50);Runnable r = () -> {   System.out.println("phase-0");   phaser.arriveAndAwaitAdvance();   System.out.println("phase-1");   phaser.arriveAndAwaitAdvance();   System.out.println("phase-2");   phaser.arriveAndDeregister();};
ExecutorService executor = Executors.newFixedThreadPool(50);for (int i = 0; i < 50; i++) { executor.submit(r);}
复制代码


如下是执行上述代码的结果:



原文链接:


https://piotrminkowski.com/2022/01/05/useful-unknown-java-features/

2022-02-07 15:334905

评论

发布
暂无评论
发现更多内容

Dynamic Wallpaper for Mac(精美的动态壁纸)v17.1免激活版

Rose

GOGC 2024 等你来

非凸科技

开源 技术 招聘 GOGC

极限编程要完全遵守的12个实践!

敏捷开发

程序员 敏捷开发 软件开发 代码规范 极限编程

时至今日,我们还要必须用敏捷开发吗?

敏捷开发

Scrum 敏捷开发 企业管理 代码规范 敏捷团队

企业数字化离不开ERP和MES

万界星空科技

数字化转型 ERP 生产管理系统 mes 万界星空科技

天猫商品详情API返回值中的商品类型与分类

技术冰糖葫芦

API 文档 API 测试 API 优先 API Hub

Rhinoceros 7 (犀牛7)中文直装破解版 三维建模软件

Rose

人工智能丨利用人工智能自动找bug

测试人

软件测试

Desktop Goose for Mac(抖音桌面宠物鹅)v0.22激活版

Rose

合合信息参编“生成式人工智能个人信息保护技术要求系列标准”,助力AI行业可信发展

合合技术团队

合合信息 #科技 生成式人工智能

四大核心能力再升级 Bonree ONE 3.0引领全域可观测进入next level

博睿数据

汇聚数字智慧 构建新质未来——《CMG数字中国》融媒体节目正式上线

江湖老铁

Sketch for mac(专业矢量绘图设计软件)v99.1中文激活版

Rose

Autodesk AutoCAD 2022破解版(CAD 2022中文版安装教程)mac/win

Rose

GPT-4o Mini深夜突发:即刻免费上线,API降价60%

蓉蓉

GPT-4o mini

文献解读-群体测序-第二十四期|《中国西部一个连续临床疑似儿童原发性腔毛运动障碍队列的临床和遗传特征》

INSVAST

基因测序 基因数据分析 生信服务

5家券商综合评级上升 6月券商App终端业务体验评测报告发布

博睿数据

硅纪元视角 | GPT-4o mini限时免费微调,每天200万免费token

硅纪元

openai GPT-4o mini Minimax

Microsoft 365 for Mac(Office 365)v16.80正式激活版

Rose

电脑风扇控制软件Macs Fan Control Pro mac破解版下载

Rose

如何安装 微信伴侣WechatTweak for mac(微信防撤回、多开助手)

Rose

现在有什么赛道可以干到退休?

王中阳Go

Go 面试

在心大陆的AI童话世界里,每个孩子都拥有“幸福陪伴”

心大陆多智能体

智能体 AI大模型 心理健康 数字心理 陪伴机器人

专业的mac软件下载平台——macw(苹果mac破解软件、资讯教程、视频、模板、壁纸素材)

Rose

MobPush标签推送新范式,精准触达再升级!

MobTech袤博科技

开发者 产品动态

技术同学的职场生存指南

老张

职业规划 认知提升 打工人 职场发展

LRC2022中文破解资源 Lightroom Classic 2022下载 mac/win

Rose

那些有用但不为大家所熟知的 Java 特性_语言 & 开发_Piotr Mińkowski_InfoQ精选文章