nkeim

nkeim

def imap_throttled(func, iterable, load_balanced_view=None, 
                   wait_interval=0.05, buffer_factor=3):
    """Asynchronous parallel "imap()" with bounded buffer.
    
    The accumulation of computed results in memory is limited
    to 'buffer_factor' times the number of nodes.
    
    Parameters:
        func : function
            func(x) will be called for each input item, as in map().

nkeim

nkeim

make notebooks
make -C tutorial notebooks
ipython nbconvert --to rst ../../../trackpy-examples/notebooks/walkthrough.ipynb
[NbConvertApp] Using existing profile dir: u'/Users/nkeim/.ipython/profile_default'
[NbConvertApp] Converting notebook ../../../trackpy-examples/notebooks/walkthrough.ipynb to rst
[NbConvertApp] Support files will be in walkthrough_files/
Traceback (most recent call last):
  File "/Users/nkeim/anaconda/bin/ipython", line 6, in <module>
    sys.exit(start_ipython())
  File "/Users/nkeim/anaconda/lib/python2.7/site-packages/IPython/__init__.py", line 120, in start_ipython

nkeim

import numpy as np

def fast_hist(data, bin_edges):
    """Fast 1-dimensional histogram. Comparable to numpy.histogram(), but careless.
    
    'bin_edges' should encompass all values in 'data'; the first and last elements 
    in 'bin_edges' are ignored, and are effectively (-infinity, infinity).

    Returns the histogram array only.
    """