Package org.apache.hc.core5.benchmark

Class BenchmarkWorker

java.lang.Object

org.apache.hc.core5.benchmark.BenchmarkWorker

All Implemented Interfaces:

ResourceHolder

class BenchmarkWorker
extends Object
implements ResourceHolder

Field Summary

Fields

Modifier and Type	Field	Description
private final CountDownLatch	completionLatch
private final BenchmarkConfig	config
private final HttpCoreContext	context
private final AtomicReference<AsyncClientEndpoint>	endpointRef
private final HttpHost	host
private final AtomicLong	requestCount
private final HttpAsyncRequester	requester
private final Stats	stats

Constructor Summary

Constructors

Constructor	Description
BenchmarkWorker(HttpAsyncRequester requester, HttpHost host, HttpCoreContext context, AtomicLong requestCount, CountDownLatch completionLatch, Stats stats, BenchmarkConfig config)

Method Summary

Modifier and Type	Method	Description
private AsyncRequestProducer	createRequestProducer()
private AsyncResponseConsumer<Void>	createResponseConsumer()
void	execute()
void	releaseResources()

Methods inherited from class java.lang.Object

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

Field Details

requester

private final HttpAsyncRequester requester

host

private final HttpHost host

context

private final HttpCoreContext context

requestCount

private final AtomicLong requestCount

completionLatch

private final CountDownLatch completionLatch

stats

private final Stats stats

config

private final BenchmarkConfig config

endpointRef

private final AtomicReference<AsyncClientEndpoint> endpointRef

Constructor Details

BenchmarkWorker

public BenchmarkWorker(HttpAsyncRequester requester,
 HttpHost host,
 HttpCoreContext context,
 AtomicLong requestCount,
 CountDownLatch completionLatch,
 Stats stats,
 BenchmarkConfig config)

Method Details

createRequestProducer

private AsyncRequestProducer createRequestProducer()

createResponseConsumer

private AsyncResponseConsumer<Void> createResponseConsumer()

execute

public void execute()

releaseResources

public void releaseResources()

Specified by:

releaseResources in interface ResourceHolder