com.alibaba.jvm.sandbox.api.http.printer

类 ConcurrentLinkedQueuePrinter

java.lang.Object

com.alibaba.jvm.sandbox.api.http.printer.ConcurrentLinkedQueuePrinter

所有已实现的接口:

Printer

public class ConcurrentLinkedQueuePrinter
extends Object
implements Printer

高性能文本输出 高性能背后的代价就是相对比较高的CPU开销

作者:

luanjia@taobao.com

构造器概要

构造器

构造器和说明
ConcurrentLinkedQueuePrinter(PrintWriter writer) 构造文本输出 delayStepTimeMs=20 delayMaxTimeMs=200 Integer.MAX_VALUE
ConcurrentLinkedQueuePrinter(PrintWriter writer, long delayStepTimeMs, long delayMaxTimeMs, int capacity) 构造文本输出

方法概要

限定符和类型	方法和说明
Printer	broken() 打断 将会唤醒因Printer.waitingForBroken()或Printer.waitingForBroken(long, TimeUnit)而被阻塞的线程
void	close() 关闭输出
Printer	flush() 刷盘
boolean	isBroken() 是否已经被打断
Printer	print(String string) 输出文本
Printer	println(String string) 输出文本
Printer	waitingForBroken() 挂起当前线程，等待被打断 线程挂起等待输出被打断 因为HTTP请求是短连接，所以这里为了避免线程立即返回，可以使用这个方法来阻塞当前Http请求响应线程，直至阻塞被中断 被打断过的请求无法再次被挂起等待，当曾经被调用过Printer.broken()之后，再次调用本方法将无法阻塞当前线程 有两种场景会打断本次挂起,任何以下场景都能结束并唤醒当前被阻塞的线程 网络I/O被中断 Printer.broken()被调用 Thread.interrupt()被调用
boolean	waitingForBroken(long time, TimeUnit unit) 挂起当前线程，等待被打断或超时 Printer.waitingForBroken()

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

ConcurrentLinkedQueuePrinter

public ConcurrentLinkedQueuePrinter(PrintWriter writer,
                                    long delayStepTimeMs,
                                    long delayMaxTimeMs,
                                    int capacity)

构造文本输出

参数:

writer - PrintWriter

delayStepTimeMs - 轮空延时步长(单位毫秒) Printer会每隔这个时间间隔检查是否有输出,如果没有任何输出则会延时累加, 整体累加延时不会超过delayMaxTimeMs

delayMaxTimeMs - 最大轮空延时

capacity - 队列最大容量 超过最大容量的输入将会被主动丢弃

ConcurrentLinkedQueuePrinter

public ConcurrentLinkedQueuePrinter(PrintWriter writer)

构造文本输出

• delayStepTimeMs=20
• delayMaxTimeMs=200
• Integer.MAX_VALUE

参数:

writer - PrintWriter

方法详细资料

print

public Printer print(String string)

从接口复制的说明: Printer

输出文本

指定者:

print 在接口中 Printer

参数:

string - 文本

返回:

this

println

public Printer println(String string)

从接口复制的说明: Printer

输出文本

指定者:

println 在接口中 Printer

参数:

string - 文本

返回:

this

flush

public Printer flush()

从接口复制的说明: Printer

刷盘

指定者:

flush 在接口中 Printer

返回:

this

waitingForBroken

public Printer waitingForBroken()

从接口复制的说明: Printer

挂起当前线程，等待被打断

线程挂起等待输出被打断

因为HTTP请求是短连接，所以这里为了避免线程立即返回，可以使用这个方法来阻塞当前Http请求响应线程，直至阻塞被中断

被打断过的请求无法再次被挂起等待，当曾经被调用过Printer.broken()之后，再次调用本方法将无法阻塞当前线程

有两种场景会打断本次挂起,任何以下场景都能结束并唤醒当前被阻塞的线程

1. 网络I/O被中断
2. Printer.broken()被调用
3. Thread.interrupt()被调用

指定者:

waitingForBroken 在接口中 Printer

返回:

this

waitingForBroken

public boolean waitingForBroken(long time,
                                TimeUnit unit)

从接口复制的说明: Printer

挂起当前线程，等待被打断或超时 Printer.waitingForBroken()

指定者:

waitingForBroken 在接口中 Printer

参数:

time - 超时时间

unit - 超时时间单位

返回:

FALSE:在超时时间到达之前返回;TRUE:因超时而返回;

broken

public Printer broken()

从接口复制的说明: Printer

打断

将会唤醒因Printer.waitingForBroken()或Printer.waitingForBroken(long, TimeUnit)而被阻塞的线程

指定者:

broken 在接口中 Printer

返回:

this

isBroken

public boolean isBroken()

从接口复制的说明: Printer

是否已经被打断

指定者:

isBroken 在接口中 Printer

返回:

TRUE:已被打断;FALSE:尚未被打断 已经被打断的输出器无法再次被Printer.waitingForBroken()挂起

close

public void close()

从接口复制的说明: Printer

关闭输出

指定者:

close 在接口中 Printer