Gakkiyomi 👋🏼

Semaphore是一种经典的同步工具，用于控制并发线程数，它可以保证在同一时间内只有一定数量的线程能够访问某个资源，从而避免线程间的竞争和冲突。 Semaphore有两个核心概念： 许可证（Permit）：表示可用的访问权限数量，Semaphore内部维护了一个许可证池，初始时可以设置许可证的数量。 信号量（Semaphore）：表示一个计数器，当线程想要访问某个资源时，必须先从Semaphore中获取一个许可证，然后才能访问资源；当线程使用完资源后，必须释放许可证，以便其他线程可以访问资源。 Semaphore的使用方式如下： 创建Semaphore对象，指定许可证数量。 在需要访问共享资源的线程中，调用acquire()方法获取许可证。 线程使用共享资源。 在共享资源使用完毕后，调用release()方法释放许可证。 听起来有点像操作系统里面信号量的概念，其实本质是一样的，不过操作系统层面的信号量是作用于进程与进程之间的同步，java里面的信号量是线程与线程之间的同步。 下面是一个简单的示例代码，使用Semaphore控制了同时执行的线程数目： import java.....

CyclicBarrier也是Java中的一个同步工具类，它允许一组线程等待彼此达到一个共同的屏障点，直到所有线程都到达屏障点后才能继续执行。CyclicBarrier可以被认为是一个可重用的计数器，每当一个线程到达屏障点时，计数器减1，当计数器减为0时，表示所有线程都已到达屏障点，等待的线程可以继续执行。 API CyclicBarrier的常用方法有两个： int await()：表示一个线程已经到达屏障点，等待其他线程，如果所有线程都到达屏障点，则计数器重置，并且所有线程都继续执行； int await(long timeout, TimeUnit unit)：表示一个线程已经到达屏障点，等待其他线程，如果所有线程都到达屏障点，则计数器重置，并且所有线程都继续执行；如果超时则抛出TimeoutException异常。 以下是一个使用CyclicBarrier进行线程同步的示例代码： import java.util.concurrent.BrokenBarrierException; import java.util.concurrent.CyclicBarrier; p....

继续 Java标准库API系列文章，今天要讲的是一个同步利器。CountDownLatch是Java中的一个同步工具类，它允许一个或多个线程等待一组事件的发生，直到所有事件都发生后才能继续执行。CountDownLatch通过一个计数器来实现，初始化一个正整数，每当一个事件发生时，计数器减1，当计数器为0时，表示所有事件都已发生，等待的线程可以继续执行。 在没有CountDownLatch之前，我们想让线程等待其他线程执行完之前等待话，需要使用到Thread类的join方法 就像之前 Java 标准库API系列之Exchanger的例子里的一样。 有了CountDownLatch之后等待其他多个线程执行完成的需求就可以使用更佳方便的API了。 CountDownLatch的常用方法有两个： void countDown()：表示一个事件已经发生，将计数器减1； void await()：等待所有事件发生，如果计数器不为0，则一直等待。 以下是一个使用CountDownLatch进行线程同步的示例代码： import java.util.concurrent.CountDownLa....

《 大义觉迷录 》是清朝雍正帝亲自颁行的一部在全国发行的官方宣传资料，收录了曾静一案的上谕、曾静口供及其《归仁录》，描述了曾静从反对雍正到拥护雍正这一“大义觉迷”的过程。利用第三人称的角色为切入题材，是研究满清的重要史料。乾隆帝即位后，认为该书主要起到弄假成真的效果，在颁行之后呈现适得其反的情形，原因是书中钜细靡遗的记载反而引起人们过度的讨论，因此迅速禁绝该书。 相关人物 爱新觉罗·胤禛 也就是雍正皇帝，他执政13年期间推行了许多项的改革。但在此期间也有许多流言蜚语，说他弑父，逼母，杀弟，是史上最凶残的暴君和最大的昏君。 曾静 号 蒲潭，清代湖南省郴州永兴县人，为一秀才。雍正年间，曾与其门徒劝川陕总督岳锺琪造反而被捕，引发吕留良案。雍正帝没有处死曾静，除了把曾静的口供收录进《大义觉迷录》，还要曾静在全国各地巡讲《大义觉迷录》。乾隆帝即位后，认为曾静的罪与吕留良相当，所以不顾父训也要把曾静凌迟处死。 对线 正常的皇帝碰到这种事情，大概就是用权力蔽之或者杀之。但雍正这个铁憨憨却竟然将曾静押回京来，进行中路对线。然后以理 [难说是不是物理 ] 服人，然后让曾静带着雍正皇帝亲自对线的结果全国....

作为一名java程序员，熟练掌握java提供的标准库是非常必要的，所以有了Java 标准库API系列文章来介绍java标准库里的一些常用的工具类，了解这些标准库可以从中学习到大神贡献给java的优良的代码和理解一些操作系统的原理，例如并发等等。。。 本文会介绍juc包下的Exchanger类。 java.util.concurrent 包是 Java 5.0 提供的并发工具包(简称 JUC)包, 主要有原子操作 CAS，锁机制 AQS（可重入锁，闭锁，屏障锁等）， 并发集合（Map，Queue 等），线程池（线程池执行器，调度线程池执行器和执行器），Exchanger是Java中的一个同步工具类，它提供了一个同步点，允许两个线程在这个同步点交换数据。Exchanger实现了一种简单的交换数据模型，可以用于解决线程间通信和同步的问题。 Exchanger的常用方法有两个： exchange(V x)：交换数据，当前线程将数据x交换给另一个线程，同时等待另一个线程返回的数据； exchange(V x, long timeout, TimeUnit unit)：在指定时间内交换数据....

关于java字节码的处理，有很多工具，如bcel，asm。不过这些都需要直接跟虚拟机指令打交道。如果你不想了解虚拟机指令，可以采用javassist。javassist是jboss的一个子项目，其主要的优点，在于简单，而且快速。直接使用java编码的形式，而不需要了解虚拟机指令，就能动态改变类的结构，或者动态生成类。 ‍ 生成类 ClassPool pool = ClassPool.getDefault(); CtClass fangcongC = pool.makeClass("fangcong"); fangcongC.addField(CtField.make("public String name;",fangcongC)); fangcongC.addMethod(CtMethod.make("public String getName(){return this.name;}", fangcongC)); fangcongC.addMethod(CtMethod.make("public void setName(String name){this.name = ....

自己多次搭建nginx做站点反向代理，这里将命令组合成脚本，方便日后使用。 #!/bin/sh mkdir /srv/nginx/config echo -e "user nginx;\nworker_processes auto;\n\nerror_log /var/log/nginx/error.log notice;\npid /var/run/nginx.pid;\n\n\nevents {\n worker_connections 1024;\n}\n\n\nhttp {\n include /etc/nginx/mime.types;\n default_type application/octet-stream;\n\n log_format main '\$remote_addr - \$remote_user [\$time_local] \"\$request\" '\n '\$status \$body_bytes_sent \"\$http_referer\" '\n '\"\$http_user_agent\" \"\$http_x_forwarded_f....

查看程序内存占用 kubectl top pod -nsky ‍ 进入目标容器 kubectl exec -it -nsky <pod名称> bash 获取 java 程序进程号 jps ‍ 保存堆栈信息 jmap -dump:live,format=b,file=<文件保存位置> <java进程号> ‍ 通过 MAT 分析内存 pipeline 分析案例 1、通过 MAT 打开堆栈信息 2、打开自动生成的内存溢出分析 ‍ 发现 ConcurrentSkipListMap 占用了大量内存 点开 detail 单击大对象 选择 List objects->with incoming references 查看持有该对象引用的对象 ‍ 发现有很多的 grpc channel 对象 查看代码发现重复创建 channel ‍ bug fixed