All Implemented Interfaces:

ai.platon.pulsar.common.config.Parameterized , java.lang.AutoCloseable
```
public class WebDriverPoolManager
extends PreemptChannelSupport 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 class`	`WebDriverPoolManager.Companion`

Field Summary

Fields
Modifier and Type	Field	Description
`private final WebDriverSettings`	`driverSettings`
`private final Duration`	`idleTimeout`
`private final Map<BrowserInstanceId, LoadingWebDriverPool>`	`driverPools`
`private final Set<BrowserInstanceId>`	`retiredDriverPools`
`private final Instant`	`startTime`
`private Instant`	`lastActiveTime`
`private final Duration`	`idleTime`
`private final Boolean`	`isIdle`
`private final Meter`	`numReset`
`private final Meter`	`numTimeout`
`private final Map<String, Gauge<out Object>>`	`gauges`
`private final Integer`	`numWaiting`
`private final Integer`	`numFreeDrivers`
`private final Integer`	`numWorkingDrivers`
`private final Integer`	`numAvailableDrivers`
`private final Integer`	`numOnline`
`private final WebDriverFactory`	`driverFactory`
`private final ImmutableConfig`	`immutableConfig`
`private final Boolean`	`suppressMetrics`
`private final Boolean`	`hasEvent`
`private final Boolean`	`isNormal`
`private final Boolean`	`isPreempted`
`private final String`	`name`

Constructor Summary

Constructors
Constructor	Description
`WebDriverPoolManager(WebDriverFactory driverFactory, ImmutableConfig immutableConfig, Boolean suppressMetrics)`

Method Summary

Modifier and Type	Method	Description
`final WebDriverSettings`	`getDriverSettings()`
`final Duration`	`getIdleTimeout()`
`final Map<BrowserInstanceId, LoadingWebDriverPool>`	`getDriverPools()`
`final Set<BrowserInstanceId>`	`getRetiredDriverPools()`
`final Instant`	`getStartTime()`
`final Instant`	`getLastActiveTime()`
`final Unit`	`setLastActiveTime(Instant lastActiveTime)`
`final Duration`	`getIdleTime()`
`final Boolean`	`getIsIdle()`
`final Meter`	`getNumReset()`
`final Meter`	`getNumTimeout()`
`final Map<String, Gauge<out Object>>`	`getGauges()`
`final Integer`	`getNumWaiting()`
`final Integer`	`getNumFreeDrivers()`
`final Integer`	`getNumWorkingDrivers()`
`final Integer`	`getNumAvailableDrivers()`
`final Integer`	`getNumOnline()`
`final WebDriverFactory`	`getDriverFactory()`
`final ImmutableConfig`	`getImmutableConfig()`
`final Boolean`	`getSuppressMetrics()`
`final Boolean`	`getHasEvent()`
`final Boolean`	`getIsNormal()`
`final Boolean`	`getIsPreempted()`
`final String`	`getName()`
`final <R extends Any> R`	`run(FetchTask task, SuspendFunction1<WebDriver, R> browseFun)`
`final <R extends Any> R`	`run(BrowserInstanceId browserId, FetchTask task, SuspendFunction1<WebDriver, R> browseFun)`	TODO: consider pro-actor model insteadreactor: tell me if you can do this job proactor: here is a job, tell me if you finished it
`final <R extends Any> R`	`run(WebDriverTask<R> task)`
`final LoadingWebDriverPool`	`createUnmanagedDriverPool(BrowserInstanceId browserId, Integer priority)`	Create a driver pool, but the driver pool is not added to driverPools
`final Boolean`	`isRetiredPool(BrowserInstanceId browserId)`
`final WebDriver`	`cancel(String url)`	Cancel the fetch task specified by url remotely.
`final WebDriver`	`cancel(BrowserInstanceId browserId, String url)`	Cancel the fetch task specified by url remotely NOTE: A cancel request should run immediately not waiting for any browser task return
`final Unit`	`cancelAll()`	Cancel all the fetch tasks, stop loading all pages
`final Unit`	`cancelAll(BrowserInstanceId browserId)`	Cancel all the fetch tasks, stop loading all pages
`final Unit`	`closeDriverPool(BrowserInstanceId browserId, Duration timeToWait)`	Cancel all running tasks and close all web drivers
`final String`	`formatStatus(BrowserInstanceId browserId, Boolean verbose)`
`Unit`	`close()`
`String`	`toString()`

Methods inherited from class ai.platon.pulsar.protocol.browser.driver.WebDriverPoolManager
formatPreemptChannelStatus, getParams, preempt, releaseLocks, whenNormal, whenNormalDeferred
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WebDriverPoolManager

WebDriverPoolManager(WebDriverFactory driverFactory, ImmutableConfig immutableConfig, Boolean suppressMetrics)

Method Detail

getDriverSettings

 final WebDriverSettings getDriverSettings()

getIdleTimeout
```
 final Duration getIdleTimeout()
```

getDriverPools

 final Map<BrowserInstanceId, LoadingWebDriverPool> getDriverPools()

getRetiredDriverPools

 final Set<BrowserInstanceId> getRetiredDriverPools()

getStartTime
```
 final Instant getStartTime()
```

getLastActiveTime
```
 final Instant getLastActiveTime()
```

setLastActiveTime

 final Unit setLastActiveTime(Instant lastActiveTime)

getIdleTime
```
 final Duration getIdleTime()
```

getIsIdle
```
 final Boolean getIsIdle()
```

getNumReset
```
 final Meter getNumReset()
```

getNumTimeout
```
 final Meter getNumTimeout()
```

getGauges

 final Map<String, Gauge<out Object>> getGauges()

getNumWaiting
```
 final Integer getNumWaiting()
```

getNumFreeDrivers
```
 final Integer getNumFreeDrivers()
```

getNumWorkingDrivers
```
 final Integer getNumWorkingDrivers()
```

getNumAvailableDrivers
```
 final Integer getNumAvailableDrivers()
```

getNumOnline
```
 final Integer getNumOnline()
```

getDriverFactory

 final WebDriverFactory getDriverFactory()

getImmutableConfig

 final ImmutableConfig getImmutableConfig()

getSuppressMetrics
```
 final Boolean getSuppressMetrics()
```

getHasEvent
```
 final Boolean getHasEvent()
```

getIsNormal
```
 final Boolean getIsNormal()
```

getIsPreempted
```
 final Boolean getIsPreempted()
```

getName
```
 final String getName()
```

run

 final <R extends Any> R run(FetchTask task, SuspendFunction1<WebDriver, R> browseFun)

run
```
 final <R extends Any> R run(BrowserInstanceId browserId, FetchTask task, SuspendFunction1<WebDriver, R> browseFun)
```
TODO: consider pro-actor model instead
reactor: tell me if you can do this job proactor: here is a job, tell me if you finished it

run

 final <R extends Any> R run(WebDriverTask<R> task)

createUnmanagedDriverPool

 final LoadingWebDriverPool createUnmanagedDriverPool(BrowserInstanceId browserId, Integer priority)

Create a driver pool, but the driver pool is not added to driverPools

isRetiredPool

 final Boolean isRetiredPool(BrowserInstanceId browserId)

cancel
```
 final WebDriver cancel(String url)
```
Cancel the fetch task specified by url remotely. NOTE: A cancel request should run immediately not waiting for any browser task return.

cancel
```
 final WebDriver cancel(BrowserInstanceId browserId, String url)
```
Cancel the fetch task specified by url remotely NOTE: A cancel request should run immediately not waiting for any browser task return

cancelAll
```
 final Unit cancelAll()
```
Cancel all the fetch tasks, stop loading all pages

cancelAll
```
 final Unit cancelAll(BrowserInstanceId browserId)
```
Cancel all the fetch tasks, stop loading all pages

closeDriverPool

 final Unit closeDriverPool(BrowserInstanceId browserId, Duration timeToWait)

Cancel all running tasks and close all web drivers

formatStatus

 final String formatStatus(BrowserInstanceId browserId, Boolean verbose)

close
```
 Unit close()
```

toString
```
 String toString()
```

Class WebDriverPoolManager

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class ai.platon.pulsar.protocol.browser.driver.WebDriverPoolManager

Methods inherited from class java.lang.Object

Constructor Detail

WebDriverPoolManager

Method Detail

getDriverSettings

getIdleTimeout

getDriverPools

getRetiredDriverPools

getStartTime

getLastActiveTime

setLastActiveTime

getIdleTime

getIsIdle

getNumReset

getNumTimeout

getGauges

getNumWaiting

getNumFreeDrivers

getNumWorkingDrivers

getNumAvailableDrivers

getNumOnline

getDriverFactory

getImmutableConfig

getSuppressMetrics

getHasEvent

getIsNormal

getIsPreempted

getName

run

run

run

createUnmanagedDriverPool

isRetiredPool

cancel

cancel

cancelAll

cancelAll

closeDriverPool

formatStatus

close

toString