Use double caching for re._compile()

The caching algorithm for re._compile() is one of the hottest sites in the stdlib. It was rewritten many times (it is not all changes):

The patch for using lru_cache() was repeatedly applied and reverted 3 times! Eventually it turned out to be slower than a simple dict lookup. It does not fit very well in this case, because some results should be not cached, and additional checks should be added before calling the cached function, adding significant overhead.

But the LRU caching algorithm can have advantage over the current simple algorithm if not all compiler patterns fit in the cache. It removes entries from the cache more smarty.

I tested with random keys with exponential distribution. With the cache size 512, the largest difference is for lambda between 1/70 and 1/80. The LRU caching algorithm has 3 times less misses: 0.16% to 0.33% against 0.5 to 1.1% misses in the current algorithm. For significantly larger (almost no misses) or smaller (tens percent of misses) lambda both algorithms gives almost the same result.

Direct implementation of the LRU caching algorithm using OrderedDict or just dict would be slower, because every hit requires moving the found entry to the end. But we can use double caching. The primary smaller and faster cache does not reorder entries. But if the key is not found in the primary cache, we look it up in the secondary LRU cache. This algorithm has the same number of misses as the LRU caching algorithm, but it has faster hits.

pythongh-96346: Use double caching for re._compile()

The code that I used to count cache misses:

Details

from random import expovariate
from collections import OrderedDict

def test(lambd, _MAXCACHE=512, *, n=10**6):
    _cache = {}
    m = 0
    for i in range(n):
        key = int(expovariate(lambd))
        try:
            _cache[key]
        except KeyError:
            m += 1
            if len(_cache) >= _MAXCACHE:
                # Drop the oldest item
                try:
                    del _cache[next(iter(_cache))]
                except (StopIteration, RuntimeError, KeyError):
                    pass
            _cache[key] = [key]
    return m/n

def test2(lambd, _MAXCACHE=512, *, n=10**6):
    _cache = OrderedDict()
    m = 0
    for i in range(n):
        key = int(expovariate(lambd))
        try:
            v = _cache[key]
        except KeyError:
            m += 1
            if len(_cache) >= _MAXCACHE:
                # Drop the least recently item
                _cache.popitem(last=False)
            _cache[key] = [key]
        else:
            _cache.move_to_end(key)
    return m/n

def test3(lambd, _MAXCACHE=512, _MAXCACHE2=256, *, n=10**6):
    _cache = {}
    _cache2 = OrderedDict()
    m = 0
    for i in range(n):
        key = int(expovariate(lambd))
        try:
            _cache[key]
        except KeyError:
            try:
                v = _cache2[key]
            except KeyError:
                m += 1
                if len(_cache2) >= _MAXCACHE:
                    # Drop the least recently item
                    _cache2.popitem(last=False)
                _cache2[key] = v = [key]
            else:
                _cache2.move_to_end(key)
            if len(_cache) >= _MAXCACHE2:
                # Drop the oldest item
                try:
                    del _cache[next(iter(_cache))]
                except (StopIteration, RuntimeError, KeyError):
                    pass
                #_cache.clear()
            _cache[key] = v
    return m/n

For example:

$ ./python -i re_cache.py
>>> a=70; x=test(1/a); y=test2(1/a); z=test3(1/a); x, y, x/y, x/z, z/y
(0.005344, 0.001695, 3.152802359882006, 3.29064039408867, 0.9581120943952803)
>>> a=80; x=test(1/a); y=test2(1/a); z=test3(1/a); x, y, x/y, x/z, z/y
(0.011016, 0.003435, 3.2069868995633186, 3.178303519907675, 1.0090247452692866)
>>> a=40; x=test(1/a); y=test2(1/a); z=test3(1/a); x, y, x/y, x/z, z/y
(0.000433, 0.000423, 1.0236406619385343, 1.0212264150943395, 1.0023640661938535)
>>> a=400; x=test(1/a); y=test2(1/a); z=test3(1/a); x, y, x/y, x/z, z/y
(0.493634, 0.445853, 1.1071676090550024, 1.0859027154497298, 1.019582687567427)

Since it involves random simulation, the results vary from run to run by few percents.

You can see that FIFO and LRU are equally good or bad for large and small lambda, and that combined algorithm is equal to LRU for the number of misses.

It does not work well if the caches has the same or close size:

>>> a=80; x=test(1/a); y=test2(1/a); z=test3(1/a, 512, 512); x, y, x/y, x/z, z/y
(0.011229, 0.003424, 3.279497663551402, 1.0396259605592075, 3.154497663551402)
>>> a=80; x=test(1/a); y=test2(1/a); z=test3(1/a, 512, 500); x, y, x/y, x/z, z/y
(0.010768, 0.003442, 3.1284137129575824, 1.8033830179199464, 1.7347472399767576)

But if the FIFO cache has size equal to 1/2 or 3/4 of the size of the LRU cache, the difference is negligible.

>>> a=80; x=test(1/a); y=test2(1/a); z=test3(1/a, 512, 256); x, y, x/y, x/z, z/y
(0.011022, 0.003399, 3.2427184466019416, 3.265777777777778, 0.9929390997352162)
>>> a=80; x=test(1/a); y=test2(1/a); z=test3(1/a, 512, 384); x, y, x/y, x/z, z/y
(0.010715, 0.00333, 3.2177177177177176, 3.0977161029199194, 1.0387387387387386)

Smaller size reduces the usefulness of the FIFO cache and can increase the average latency. Above tests do not measure latency, they only evaluate miss rate.

It was only theory. Here is an artificial example which shows that the optimization actually helps:

$ ./python -m timeit -n50000 -s 'from random import expovariate; from re import compile; lambd=1/80' 'compile(r"[az1\0-\uffff]"+str(int(expovariate(lambd))))'

Unpatched: 50000 loops, best of 5: 34.5 usec per loop
Patched: 50000 loops, best of 5: 17.9 usec per loop

The results are unstable, but in this case the patched variant is for sure faster than the baseline. In other examples the difference can be not such significant, and I have no any estimations what effect it has in real world code.

gh-96346: Use double caching for re._compile() (#96347)

Thanks, Serhiy! ✨ 🍰 ✨

Merge branch 'main' into typewatch

pythongh-96346: Use double caching for re._compile() (python#96347)

Navigation Menu

Repository navigation

Use double caching for re._compile() #96346

Metadata

Assignees

Labels

Projects

Milestone

Relationships

Development

Use double caching for re._compile() #96346

Description

Activity

serhiy-storchaka commented on Aug 28, 2022

serhiy-storchaka commented on Aug 28, 2022

ambv commented on Oct 7, 2022

Metadata

Metadata

Assignees

Labels

Projects

Milestone

Relationships

Development

Issue actions