-
- 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 Collection<WebDriver>onlineDriversprivate final Collection<WebDriver>freeDriversprivate final CountercounterRetiredprivate final CountercounterQuitprivate BooleanisRetiredprivate final BooleanisActiveprivate final AtomicBooleanlaunchedprivate final AtomicIntegernumWaitingprivate final AtomicIntegernumWorkingprivate final IntegernumFreeprivate final IntegernumActiveprivate final IntegernumAvailableprivate final IntegernumOnlineprivate InstantlastActiveTimeprivate DurationidleTimeoutprivate final DurationidleTimeprivate final BooleanisIdleprivate final BrowserIdbrowserIdprivate final Integerpriorityprivate final WebDriverFactorydriverFactoryprivate final ImmutableConfigimmutableConfig
-
Constructor Summary
Constructors Constructor Description LoadingWebDriverPool(BrowserId browserId, Integer priority, WebDriverFactory driverFactory, ImmutableConfig immutableConfig)
-
Method Summary
Modifier and Type Method Description final IntegergetId()final IntegergetCapacity()final Collection<WebDriver>getOnlineDrivers()final Collection<WebDriver>getFreeDrivers()final CountergetCounterRetired()final CountergetCounterQuit()final BooleangetIsRetired()final UnitsetIsRetired(Boolean isRetired)final BooleangetIsActive()final AtomicBooleangetLaunched()final AtomicIntegergetNumWaiting()final AtomicIntegergetNumWorking()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 BrowserIdgetBrowserId()final IntegergetPriority()final WebDriverFactorygetDriverFactory()final ImmutableConfiggetImmutableConfig()final Unitallocate(VolatileConfig conf)Allocate capacity drivers final WebDriverpoll()Retrieves and removes the head of this free driver queue, or returns {@code null} if there is no free drivers. 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 WebDriverfirstOrNull(Function1<WebDriver, Boolean> predicate)final UnitcancelAll()Cancel all the fetch tasks, stop loading all pages Unitclose()final StringformatStatus(Boolean verbose)StringtoString()-
-
Constructor Detail
-
LoadingWebDriverPool
LoadingWebDriverPool(BrowserId browserId, Integer priority, WebDriverFactory driverFactory, ImmutableConfig immutableConfig)
-
-
Method Detail
-
getCapacity
final Integer getCapacity()
-
getOnlineDrivers
final Collection<WebDriver> getOnlineDrivers()
-
getFreeDrivers
final Collection<WebDriver> getFreeDrivers()
-
getCounterRetired
final Counter getCounterRetired()
-
getCounterQuit
final Counter getCounterQuit()
-
getIsRetired
final Boolean getIsRetired()
-
setIsRetired
final Unit setIsRetired(Boolean isRetired)
-
getIsActive
final Boolean getIsActive()
-
getLaunched
final AtomicBoolean getLaunched()
-
getNumWaiting
final AtomicInteger getNumWaiting()
-
getNumWorking
final AtomicInteger getNumWorking()
-
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()
-
getBrowserId
final BrowserId getBrowserId()
-
getPriority
final Integer getPriority()
-
getDriverFactory
final WebDriverFactory getDriverFactory()
-
getImmutableConfig
final ImmutableConfig getImmutableConfig()
-
poll
final WebDriver poll()
Retrieves and removes the head of this free driver queue, or returns {@code null} if there is no free drivers.
-
poll
final WebDriver poll(VolatileConfig conf)
-
firstOrNull
final WebDriver firstOrNull(Function1<WebDriver, Boolean> predicate)
-
formatStatus
final String formatStatus(Boolean verbose)
-
-
-
-