-
- All Implemented Interfaces:
-
ai.platon.pulsar.common.config.Parameterized,java.lang.AutoCloseable
public final class LoadingWebDriverPool implements Parameterized, AutoCloseable
Created by vincent on 18-1-1. Copyright @ 2013-2017 Platon AI. All rights reserved
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description public classLoadingWebDriverPool.Companion
-
Field Summary
Fields Modifier and Type Field Description private final Integeridprivate final Integercapacityprivate final ConcurrentSkipListSet<WebDriver>onlineDriversprivate final ArrayBlockingQueue<WebDriver>freeDriversprivate final CountercounterRetiredprivate final CountercounterQuitprivate BooleanisRetiredprivate final BooleanisActiveprivate final AtomicIntegernumWaitingprivate final AtomicIntegernumWorkingprivate final AtomicIntegernumTasksprivate final AtomicIntegernumSuccessprivate final AtomicIntegernumTimeoutprivate final AtomicIntegernumDismissWarningsprivate final IntegermaxDismissWarningsprivate final BooleanshouldRetireprivate final IntegernumFreeprivate final IntegernumActiveprivate final IntegernumAvailableprivate final IntegernumOnlineprivate InstantlastActiveTimeprivate DurationidleTimeoutprivate final DurationidleTimeprivate final BooleanisIdle
-
Constructor Summary
Constructors Constructor Description LoadingWebDriverPool(BrowserInstanceId browserInstanceId, Integer priority, WebDriverFactory driverFactory, ImmutableConfig conf)
-
Method Summary
Modifier and Type Method Description final IntegergetId()final IntegergetCapacity()final ConcurrentSkipListSet<WebDriver>getOnlineDrivers()final ArrayBlockingQueue<WebDriver>getFreeDrivers()final CountergetCounterRetired()final CountergetCounterQuit()final BooleangetIsRetired()final UnitsetIsRetired(Boolean isRetired)final BooleangetIsActive()final AtomicIntegergetNumWaiting()final AtomicIntegergetNumWorking()final AtomicIntegergetNumTasks()final AtomicIntegergetNumSuccess()final AtomicIntegergetNumTimeout()final AtomicIntegergetNumDismissWarnings()final IntegergetMaxDismissWarnings()final BooleangetShouldRetire()final IntegergetNumFree()final IntegergetNumActive()final IntegergetNumAvailable()final IntegergetNumOnline()final InstantgetLastActiveTime()final UnitsetLastActiveTime(Instant lastActiveTime)final DurationgetIdleTimeout()final UnitsetIdleTimeout(Duration idleTimeout)final DurationgetIdleTime()final BooleangetIsIdle()final Unitallocate(VolatileConfig volatileConfig)Allocate capacity drivers final WebDriverpoll()final WebDriverpoll(VolatileConfig conf)final WebDriverpoll(VolatileConfig conf, Long timeout, TimeUnit unit)final WebDriverpoll(Integer priority, VolatileConfig conf, Duration timeout)final WebDriverpoll(Integer priority, VolatileConfig conf, Long timeout, TimeUnit unit)final Unitput(WebDriver driver)final UnitforEach(Function1<WebDriver, Unit> action)final <ERROR CLASS>firstOrNull(Function1<WebDriver, Boolean> predicate)Unitclose()final StringformatStatus(Boolean verbose)StringtoString()-
-
Constructor Detail
-
LoadingWebDriverPool
LoadingWebDriverPool(BrowserInstanceId browserInstanceId, Integer priority, WebDriverFactory driverFactory, ImmutableConfig conf)
-
-
Method Detail
-
getCapacity
final Integer getCapacity()
-
getOnlineDrivers
final ConcurrentSkipListSet<WebDriver> getOnlineDrivers()
-
getFreeDrivers
final ArrayBlockingQueue<WebDriver> getFreeDrivers()
-
getCounterRetired
final Counter getCounterRetired()
-
getCounterQuit
final Counter getCounterQuit()
-
getIsRetired
final Boolean getIsRetired()
-
setIsRetired
final Unit setIsRetired(Boolean isRetired)
-
getIsActive
final Boolean getIsActive()
-
getNumWaiting
final AtomicInteger getNumWaiting()
-
getNumWorking
final AtomicInteger getNumWorking()
-
getNumTasks
final AtomicInteger getNumTasks()
-
getNumSuccess
final AtomicInteger getNumSuccess()
-
getNumTimeout
final AtomicInteger getNumTimeout()
-
getNumDismissWarnings
final AtomicInteger getNumDismissWarnings()
-
getMaxDismissWarnings
final Integer getMaxDismissWarnings()
-
getShouldRetire
final Boolean getShouldRetire()
-
getNumFree
final Integer getNumFree()
-
getNumActive
final Integer getNumActive()
-
getNumAvailable
final Integer getNumAvailable()
-
getNumOnline
final Integer getNumOnline()
-
getLastActiveTime
final Instant getLastActiveTime()
-
setLastActiveTime
final Unit setLastActiveTime(Instant lastActiveTime)
-
getIdleTimeout
final Duration getIdleTimeout()
-
setIdleTimeout
final Unit setIdleTimeout(Duration idleTimeout)
-
getIdleTime
final Duration getIdleTime()
-
poll
final WebDriver poll()
-
poll
final WebDriver poll(VolatileConfig conf)
-
firstOrNull
final <ERROR CLASS> firstOrNull(Function1<WebDriver, Boolean> predicate)
-
formatStatus
final String formatStatus(Boolean verbose)
-
-
-
-