Striped resource pool based on Control.Concurrent.QSem.
Moduleresource-pool-0.5.1.0Haskell2010
Data.Pool.Introspection
A variant of Data.Pool with introspection capabilities.
- 5 types
- 11 values
- Packageresource-pool-0.5.1.0
- Exports16
- LanguageHaskell2010
- LicenceBSD-3-Clause
- SourceIntrospection.hs
Pool
3 declarationsA single, local pool.
Create a new striped resource pool.
Note: although the runtime system will destroy all idle resources when the pool is garbage collected, it's recommended to manually call destroyAllResources when you're done with the pool so that the resources are freed up as soon as possible.
Configuration
Configuration of a Pool.
defaultPoolConfig :: IO aThe action that creates a new resource.
-> (a -> IO ())The action that destroys an existing resource.
-> DoubleThe number of seconds for which an unused resource is kept around. The smallest acceptable value is
0.5.-> IntThe maximum number of resources to keep open across all stripes. The smallest acceptable value is
1per stripe.Note: if the number of stripes does not divide the number of resources, some of the stripes will have 1 more resource available than the others.
-> PoolConfig a
Create a PoolConfig with optional parameters having default values.
For setting optional parameters have a look at:
Set the number of stripes (sub-pools) in the pool.
If not explicitly set, the default number of stripes is 1, which should be good for typical use (when in doubt, profile your application first).
If set to Nothing, the pool will create the number of stripes equal to the number of capabilities.
Note: usage of multiple stripes reduces contention, but can also result in suboptimal use of resources since stripes are separated from each other.
Assign a label to the pool.
The label will appear in a label of the collector thread as well as Resource.
Resource management
9 declarationsA resource taken from the pool along with additional information.
Constructors
Resourceresource :: apoolLabel :: !TextstripeNumber :: !IntavailableResources :: !Intacquisition :: !AcquisitionacquisitionTime :: !DoublecreationTime :: !Maybe Double
Instances4Eq, Show, Generic, Rep
Eq a => Eq (Resource a)Defined in resource-pool-0.5.1.0 · Data.Pool.IntrospectionShow a => Show (Resource a)Defined in resource-pool-0.5.1.0 · Data.Pool.IntrospectionGeneric (Resource a)Defined in resource-pool-0.5.1.0 · Data.Pool.Introspectiontype Rep (Resource a) = D1 ('MetaDataDefined in resource-pool-0.5.1.0 · Data.Pool.Introspection"Resource"
"Data.Pool.Introspection"
"resource-pool-0.5.1.0-DKahF1nexcs8i0zvcLnov2"
'False) (C1 ('MetaCons"Resource"
'PrefixI 'True) ((S1 ('MetaSel ('Just"resource"
) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 a) :*: (S1 ('MetaSel ('Just"poolLabel"
) 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Text) :*: S1 ('MetaSel ('Just"stripeNumber"
) 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Int))) :*: ((S1 ('MetaSel ('Just"availableResources"
) 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Int) :*: S1 ('MetaSel ('Just"acquisition"
) 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 Acquisition)) :*: (S1 ('MetaSel ('Just"acquisitionTime"
) 'NoSourceUnpackedness 'SourceStrict 'DecidedUnpack) (Rec0 Double) :*: S1 ('MetaSel ('Just"creationTime"
) 'NoSourceUnpackedness 'SourceStrict 'DecidedStrict) (Rec0 (Maybe Double))))))
Describes how a resource was acquired from the pool.
Instances4Eq, Show, Generic, Rep
Eq AcquisitionDefined in resource-pool-0.5.1.0 · Data.Pool.IntrospectionShow AcquisitionDefined in resource-pool-0.5.1.0 · Data.Pool.IntrospectionGeneric AcquisitionDefined in resource-pool-0.5.1.0 · Data.Pool.Introspectiontype Rep Acquisition = D1 ('MetaDataDefined in resource-pool-0.5.1.0 · Data.Pool.Introspection"Acquisition"
"Data.Pool.Introspection"
"resource-pool-0.5.1.0-DKahF1nexcs8i0zvcLnov2"
'False) (C1 ('MetaCons"Immediate"
'PrefixI 'False) U1 :+: C1 ('MetaCons"Delayed"
'PrefixI 'False) U1)
withResource with introspection capabilities.
takeResource with introspection capabilities.
A variant of withResource that doesn't execute the action and returns Nothing instead of blocking if the local pool is exhausted.
A variant of takeResource that returns Nothing instead of blocking if the local pool is exhausted.
Return a resource to the given LocalPool.
Destroy a resource.
Note: since version 0.5.0.0 exceptions thrown by the destroy function are no longer ignored.
Destroy all resources in all stripes in the pool.
Note that this will ignore any exceptions in the destroy function.
This function is useful when you detect that all resources in the pool are
broken. For example after a database has been restarted all connections
opened before the restart will be broken. In that case it's better to close
those connections so that takeResource won't take a broken connection from
the pool but will open a new connection instead.
Another use-case for this function is that when you know you are done with the pool you can destroy all idle resources immediately instead of waiting on the garbage collector to destroy them, thus freeing up those resources sooner.