前面我们提到线程池处理批量接口请求实践但是在语法上比较复杂,还需要进行线程间的同步,也需要一定的 Java 知识,最近在学习 Golang 语言时,感觉go关键字十分高效,只要是想异步执行的方法,只需在前面添加go关键字即可。

如果 Java 也能实现一个类似go的关键字,那该多好啊!

思路

Java 本身也是支持闭包的,通过闭包重建一个java.lang.Runnable的匿名实现类,然后创建线程去执行对应的方法,应该是可以实现简单异步功能。

既然 Java 都能支持,那 Groovy 肯定也有解决方案了,至少可以直接用 Java 的方案。

几种语言的闭包使用可以参考

实践

思路比较简单,下面分享一下实践过程。

Java

不同于其他语言,Java 闭包方法根据不同的参数、返回值有不同的实现类。这个地方有点烦,不够灵活。我试了java.util.function下面的多个实现类,最终选择了java.util.function.Supplier,原因是这个实现类没有参数,但是需要一个返回值。

There is no requirement that a new or distinct result be returned each time the supplier is invoked.

代码和使用方式如下:

package com.funtest.javatest;

import com.funtester.frame.SourceCode;

import java.util.function.Supplier;

public class Sync extends SourceCode {

    public static void main(String[] args) {
        sync(() -> {
            sleep(0.1);
            output("tester");
            return DEFAULT_CHARSET;
        });
        output("FunTester");
    }

    public static void sync(Supplier f) {
        new Thread(() -> {
            f.get();
        }).start();
    }

}

控制台输出:

INFO-> main 当前用户:oker,工作目录:/Users/oker/IdeaProjects/funtester/,系统编码格式:UTF-8,系统Mac OS X版本:10.16
INFO-> main FunTester
INFO-> Thread-1 tester

Process finished with exit code 0


这里先不展示 Groovy 如何使用了。后面有更精彩的。

Groovy

Groovy 语法相当简单,用一个groovy.lang.Closure解决所有问题。

代码和使用方式如下:

import com.funtester.frame.SourceCode

class Sync extends SourceCode {

    public static void main(String[] args) {

        sync {
            sleep(0.2)
            output(320)
        }
        output("FunTester")

    }


    static void sync(Closure f) {
        new Thread(f()).start()
    }
}

控制台输出:

INFO-> main 当前用户:oker,工作目录:/Users/oker/IdeaProjects/funtester/,系统编码格式:UTF-8,系统Mac OS X版本:10.16
INFO-> main FunTester
INFO-> Thread-1 tester

Process finished with exit code 0

可以看出 Groovy 语法是非常简单的,已经非常接近 Golang 语言 go 关键字的体验了,仅仅从语法上,性能上的问题以后会再讨论。

线程池升级

因为 Golang 语言有自己的 goroutine 管理器,加上 Golang 特性,所以不是用很担心创建过多的协程消耗更多资源。但是 Java 还是要考虑一下的,为了解决测试过程中创建过多线程导致异常出现,我用线程池解决这个问题。通过将闭包中的方法包装成java.lang.Runnable对象,丢给线程池去执行。

封装方法如下:

/**
 * 异步执行某个代码块
 * Java调用需要return,Groovy也不需要,语法兼容
 *
 * @param f
 */
public static void fun(Supplier f) {
    Runnable runnable = new Runnable() {
        @Override
        public void run() {
            f.get();
        }
    };
    ThreadPoolUtil.executeSync(runnable);
}

这里我选用了 Java 的语法,为什么不用 Groovy 的方法封装呢?因为 Groovy 完全兼容了 Java 的语法而不失去 Groovy 自己的特性。

下面演示一下 Java 如何使用:

public class FunT extends FunLibrary {

    public static void main(String[] args) {

        fun(()->{
            sleep(0.1);
            output("FunTester");
            return null;
        });
        output("fds");
        ThreadPoolUtil.shutFun()    
    }

}

优先于 Java 语法,需要多写一些 code,这个我目前解决方案是通过Intellij自带的Live Templates输入代码模板解决。如图:

下面演示一下 Groovy 如何使用:

public static void main(String[] args) {

    fun {
        sleep(0.2)
        output(320)
    }
    output("FunTester")
    ThreadPoolUtil.shutFun()    
}

同样我们可以使用Intellij自带的Live Templates输入代码模板,不再展示了。

简直如丝般顺滑。

控制台输出:

INFO-> main 当前用户oker工作目录/Users/oker/IdeaProjects/funtester/,系统编码格式:UTF-8,系统Mac OS X版本:10.16
INFO-> main FunTester
INFO-> FT-1 320

Process finished with exit code 0

这里我自定义了线程的名字,方法如下:

/**
 * 自定义{@link ThreadFactory}对象
 * @return
 */
static ThreadFactory getFactory() {
    if (FunFactory == null) {
        synchronized (ThreadPoolUtil.class) {
            if (FunFactory == null) {
                FunFactory = new ThreadFactory() {

                    @Override
                    Thread newThread(Runnable runnable) {
                        Thread thread = new Thread(runnable);
                        def increment = threadNum.getAndIncrement()
                        def name = increment < 10 ? "00" + increment : increment < 100 ? "0" + increment : Constant.EMPTY + increment
                        thread.setName("FT-" + name);
                        return thread;
                    }
                }
            }
        }
    }
    return FunFactory
}

多线程同步

如果遇到有多线程同步需求,那么依旧使用java.util.concurrent.Phaser来满足需求。封装方法如下:

/**
 * 异步执行代码块,使用{@link Phaser}进行多线程同步
 *
 * @param f
 * @param phaser
 */
public static void fun(Supplier f, Phaser phaser) {
    Runnable runnable = new Runnable() {
        @Override
        public void run() {
            try {
                phaser.register();
                f.get();
            } catch (Exception e) {
                logger.warn("执行异步方法时发生错误!", e);
            } finally {
                phaser.arriveAndDeregister();
            }

        }
    };
    ThreadPoolUtil.executeSync(runnable);
}

Have Fun ~ Tester !


↙↙↙阅读原文可查看相关链接,并与作者交流