Java tps_Java static

Java tps_Java static写在前面TPS即每秒查询事物,可以用于测试一个方法、工具或者系统的性能。本文采用Java并发包中的工具实现了一个工具TPS性能测试。主要是测试OKHttp库来执行Http请求的性能。测试代码用到了Java了线程池ExecuterService,CountDownLatch,CyclicBarrier,原子类,volatile关键词等。可算是对Java并发组件的组合使用。下面直接贴出源码,仅供参考

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

写在前面

TPS即每秒查询事物,可以用于测试一个方法、工具或者系统的性能。本文采用Java并发包中的工具实现了一个工具TPS性能测试。主要是测试OKHttp库来执行Http请求的性能。测试代码用到了Java了线程池ExecuterServiceCountDownLatch, CyclicBarrier, 原子类,volatile关键词等。可算是对Java并发组件的组合使用。下面直接贴出源码,仅供参考,如有错误,欢迎指出,以期共同探讨。

TPS 实现源码

package cn.concurrent;

import java.math.RoundingMode;
import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicLong;

import util.OkHttpUtil;

import com.google.common.math.LongMath;

/** * 每秒事物执行次数统计 * * @author Xie le * @date 2016/7/9 */
public class TpsWorkbeanch { 
   

    /** 线程数量 */
    public static final int N_THRESHOLDS = 5;

    /** 30 秒总时间 */
    public static final int TIME_THRESHOLDS = 30;

    /** 用原子变量来统计执行时间,便于作原子递减 */
    private static AtomicInteger totalTime = new AtomicInteger(TIME_THRESHOLDS);

    /** 用于统计执行的事物总数,用原子方式累加记录 */
    private static AtomicLong totalExecCount = new AtomicLong(0L);

    /** 需要到等到所有线程都在同一起跑线,才开始统计计数,类似于发令枪 */
    private static CyclicBarrier barrier = new CyclicBarrier(N_THRESHOLDS);

    /** 执行时间到达时,所有的线程需要依次退出,主线程才开始统计执行事物总数 */
    private static CountDownLatch countDownLatch = new CountDownLatch(N_THRESHOLDS);

    /** 线程执行标记 , 用volatile修饰,使变量修改具有线程可见性 */
    private static volatile boolean runnning = true;

    /** 用线程池来执行统计 */
    private static ExecutorService executorService;

    /** * 用接口来作模拟统计 */
    interface Job {
        void execute() throws Exception;
    }

    /** * 具体Job,模拟完成一次Http请求 BTW:内部类用static修饰 */
    static class JobDetail implements Job {

        public void execute() throws Exception {
            String run = OkHttpUtil.run("http://publicobject.com/helloworld.txt");
        }
    }

    /** * Worker执行Job */
    static class Worker implements Runnable {

        private Job job;

        Worker(Job job) {
            this.job = job;
        }

        // 每个线程执行的事物统计量
        int innerCount = 0;

        public void run() {
            try {
                barrier.await(); // 等到所有线程都在起跑线
                while (runnning) {
                    this.job.execute();
                    innerCount++;
                }
            } catch (Exception e) {
                System.out.println("线程Id:" + Thread.currentThread().getId() + " " + e.getMessage());
            } finally {
                // 累加到总记录统计量
                System.out.println("线程Id:" + Thread.currentThread().getId() + " 执行事物次数为:" + innerCount);
                totalExecCount.getAndAdd(innerCount);
                // 线程结束后,依次计数, 便于主线程继续执行
                countDownLatch.countDown();
            }
        }
    }

    public static void run() throws Exception {
        Job job = new JobDetail(); // 创建Job
        executorService = Executors.newFixedThreadPool(N_THRESHOLDS); // 新建固定大小线程的池子
        for (int i = 0; i < N_THRESHOLDS; i++) {
            executorService.submit(new Worker(job)); // 提交线程到池子中
        }
        // 还需要一个线程,用于周期检查执行时间是否到达
        final ScheduledExecutorService scheduledExcutor = Executors.newSingleThreadScheduledExecutor();
        scheduledExcutor.scheduleAtFixedRate(new Runnable() {
            public void run() {
                if (totalTime.decrementAndGet() == 0) { // 执行时间递减到0
                    runnning = false; // 告诉线程,时间到了,所有线程不再执行
                    scheduledExcutor.shutdownNow();
                }
            }
        }, 1L, 1L, TimeUnit.SECONDS);

        // 主线程等到所有的线程都退出,则开始统计
        countDownLatch.await();

        long totalExeCount = totalExecCount.get();
        System.out.println(N_THRESHOLDS + " 个线程," + TIME_THRESHOLDS + " 秒内总共执行的事物数量:" + totalExeCount);

        long tps = LongMath.divide(totalExeCount, TIME_THRESHOLDS, RoundingMode.HALF_EVEN);

        System.out.println("OKHttp执行的TPS: " + tps);

        executorService.shutdownNow(); // 关闭线程池


    }

    public static void main(String[] args) throws Exception {

        run();
    }

}

其中用到的OKHttp类如下:

package util;

import java.io.IOException;
import java.util.concurrent.TimeUnit;

import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;

/** * OkHttp工具 * @author Xie le * @date 2016/6/30 */
public class OkHttpUtil { 
   

    private static OkHttpClient okHttpclient = null;

    static {
        okHttpclient = new OkHttpClient.Builder()
                .connectTimeout(3, TimeUnit.SECONDS)
                .build();
    }

    public static String run(String url) throws Exception {
        Request request = new Request.Builder().url(url).build();
        Response response = okHttpclient.newCall(request).execute();
        if (!response.isSuccessful()) {
            throw new IOException("Unexpected code " + response);
        }
        return response.body().string();

    }
}

测试结果

测试结果与环境有关。以我本机为例,5个线程,30秒内的测试结果如下:

线程Id:14 connect timed out
线程Id:14 执行事物次数为:0
线程Id:10 connect timed out
线程Id:10 执行事物次数为:0
线程Id:11 执行事物次数为:29
线程Id:13 执行事物次数为:33
线程Id:12 执行事物次数为:26
5 个线程,30 秒内总共执行的事物数量:88
OKHttp执行的TPS: 3

最后

直接阅读代码,可以掌握Java并发的常用的工具类。

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

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/194201.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 一个示例让你明白适配器模式

    一个示例让你明白适配器模式本文讨论适配器模式。适配器模式是23中设计模式之一,它的主要作用是在新接口和老接口之间进行适配。它非常像我们出国旅行时带的电源转换器。为了举这个例子,我还特意去京东上搜了一下电源转换器,确实看到了很多地方的标准不一样。我们国家的电器使用普通的扁平两项或三项插头,而去外国的话,使用的标准就不一样了,比如德国,使用的是德国标准,是两项圆头的插头。

  • RewriteRule参数

    RewriteRule参数在重写规制的最后,也可以附加一个或多个标记参数(用逗号分开),从而为新的URL地址添加特殊的标志。这些参数是特殊的RewriteRule命令,并且不是普通的正则表达式,下表列出了一些常用的RewriteRule参数。这些重写标记必须被置于单条规则最后的括号内,多个标记需要适用逗号分开,例如”[NC,L]”RewirteRule标记含义描述RRedirect

  • 0x80表示什么_0x38是多少

    0x80表示什么_0x38是多少0x800x是C语言中16进制数的表示方法。0x80等于十进制的1280×80在计算机内部表示为10000000字符在计算机中以其ASCII码方式表示, 其长度为1个字节,有符号字符型数取值范围为-128~127,无符号字符型数到值范围是0~255。因此在TurboC语言中,字符型数据在操作时将按整型数处理,如果某个变量定义成char,则表明该变量是

  • vue 计数器_计数器是什么

    vue 计数器_计数器是什么计数器的实现在页面上简单实现一个计数器<!DOCTYPEhtml><htmllang="en"><head><metach

  • python 去掉文件后缀名,python 删除后缀名文件

    python 去掉文件后缀名,python 删除后缀名文件Note:print语句供test用#!/usr/bin/pythonimportos,re,time,sysimportos.pathimportstringfilter_dir=”/home/fengnazh/splittest/files/”filterfile_list=os.listdir(filter_dir)printfilterfile_listfile_i…

  • Nodejs后端框架搭建(express)

    Nodejs后端框架搭建(express)文章目录1.node简介2.Express简介3.项目初始化4.Express三大基础概念(扩展)1.node简介Node是一个基于V8引擎的Javascript运行环境,它使得Javascript可以运行在服务端,直接与操作系统进行交互,与文件控制、网络交互、进程控制等2.Express简介express是一个轻量级的NodeWeb服务端框架,同样是一个人气超高的项目,它可以帮助我们快速搭建基于Node的Web应用3.项目初始化1.创建项目首先你得创

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号