diff options
author | Aaron LI <aly@aaronly.me> | 2017-08-01 18:27:43 +0800 |
---|---|---|
committer | Aaron LI <aly@aaronly.me> | 2017-08-01 18:27:43 +0800 |
commit | 4b13e8bd09d2e220aba040576e58dfa60c044c54 (patch) | |
tree | af295037451c37ea8e061fce2e2ff29c486f3827 | |
parent | 8c2b947d41346e7374269f729fe65975d6613b6e (diff) | |
download | fg21sim-4b13e8bd09d2e220aba040576e58dfa60c044c54.tar.bz2 |
clusters/emission.py: Make "F()" be class method, fixing memory hole!
For unknown reason! Each instance of "SynchrotronEmission" will cost
~5 MiB memory when interpolating the kernel function cached as
"self._F_interp", which won't be collected/freed by GC, for UNKNOWN
reason!
Therefore, make the method "F()" be class-wide, to avoid the memory hole!
Signed-off-by: Aaron LI <aly@aaronly.me>
-rw-r--r-- | fg21sim/extragalactic/clusters/emission.py | 57 |
1 files changed, 35 insertions, 22 deletions
diff --git a/fg21sim/extragalactic/clusters/emission.py b/fg21sim/extragalactic/clusters/emission.py index 9d668f7..baab1b9 100644 --- a/fg21sim/extragalactic/clusters/emission.py +++ b/fg21sim/extragalactic/clusters/emission.py @@ -32,6 +32,36 @@ from ...utils.units import (Units as AU, Constants as AC) logger = logging.getLogger(__name__) +def _interp_sync_kernel(xmin=1e-5, xmax=20.0, xsample=128): + """ + Sample the synchrotron kernel function at the specified X + positions and make an interpolation, to optimize the speed + when invoked to calculate the synchrotron emissivity. + + Parameters + ---------- + xmin, xmax : float, optional + The lower and upper cuts for the kernel function. + Default: [1e-5, 20.0] + xsample : int, optional + Number of samples within [xmin, xmax] used to do interpolation. + NOTE: The kernel function is quiet smooth and slow-varying. + + Returns + ------- + F_interp : function + The interpolated kernel function ``F(x)``. + """ + xx = np.logspace(np.log10(xmin), np.log10(xmax), num=xsample) + Fxx = [xp * integrate.quad(lambda t: scipy.special.kv(5/3, t), + a=xp, b=np.inf)[0] + for xp in xx] + F_interp = interpolate.interp1d( + xx, Fxx, kind="quadratic", bounds_error=False, + fill_value=(Fxx[0], Fxx[-1]), assume_sorted=True) + return F_interp + + class SynchrotronEmission: """ Calculate the synchrotron emissivity from a given population @@ -48,13 +78,8 @@ class SynchrotronEmission: The assumed uniform magnetic field within the cluster ICM. Unit: [uG] """ - # The lower and upper cuts for the kernel function ``F(x)``. - Fxmin = 1e-5 - Fxmax = 20.0 - # Number of samples within [Fxmin, Fxmax] to do interpolation - # for the kernel function. - # NOTE: The kernel function is quiet smooth and slow-varying. - Fsamples = 128 + # The interpolated synchrotron kernel function ``F(x)``. + F_interp = _interp_sync_kernel() def __init__(self, gamma, n_e, B): self.gamma = np.asarray(gamma) @@ -104,7 +129,8 @@ class SynchrotronEmission: nu_c = 1.5 * gamma**2 * np.sin(theta) * self.frequency_larmor return nu_c - def F(self, x): + @classmethod + def F(cls, x): """ Synchrotron kernel function. @@ -127,20 +153,7 @@ class SynchrotronEmission: y : `~numpy.ndarray` Calculated kernel function values. """ - if not hasattr(self, "_F_interp"): - # Make an interpolation and cache - xx = np.logspace(np.log10(self.Fxmin), np.log10(self.Fxmax), - num=self.Fsamples) - Fxx = [xp * integrate.quad(lambda t: scipy.special.kv(5/3, t), - a=xp, b=np.inf)[0] - for xp in xx] - self._F_interp = interpolate.interp1d(xx, Fxx, kind="quadratic") - - x = np.array(x) # Make a copy as it will be modified below! - x[x < self.Fxmin] = self.Fxmin - x[x > self.Fxmax] = self.Fxmax - y = self._F_interp(x) - return y + return cls.F_interp(x) def emissivity(self, frequencies): """ |