bulk-cdk-core-extract/io.airbyte.cdk.read/ConcurrencyResource

ConcurrencyResource

@Singleton
class ConcurrencyResource(maxConcurrency: Int) : Resource<ConcurrencyResource.AcquiredThread>

A Resource used to manage concurrency.

Constructors

Link copied to clipboard
@Inject
constructor(configuration: SourceConfiguration)
constructor(maxConcurrency: Int)

Types

Link copied to clipboard

Properties

Link copied to clipboard
val available: Int
Link copied to clipboard
open override val type: ResourceType

Functions

Link copied to clipboard
open override fun tryAcquire(): ConcurrencyResource.AcquiredThread?

Attempts to acquire the resource.