|
| 1 | +from __future__ import annotations |
| 2 | + |
| 3 | +import concurrent.futures |
| 4 | + |
| 5 | +import pendulum |
| 6 | + |
| 7 | + |
| 8 | +ITERATIONS = 200 |
| 9 | +WORKERS = 8 |
| 10 | + |
| 11 | + |
| 12 | +def _run_parallel(fn, *args): |
| 13 | + with concurrent.futures.ThreadPoolExecutor(max_workers=WORKERS) as pool: |
| 14 | + futures = [pool.submit(fn, *args) for _ in range(ITERATIONS)] |
| 15 | + return [f.result() for f in futures] |
| 16 | + |
| 17 | + |
| 18 | +def test_parse_iso8601_threaded(): |
| 19 | + results = _run_parallel(pendulum.parse, "2024-01-15T10:30:00+00:00") |
| 20 | + expected = results[0] |
| 21 | + assert all(r == expected for r in results) |
| 22 | + |
| 23 | + |
| 24 | +def test_now_threaded(): |
| 25 | + results = _run_parallel(pendulum.now) |
| 26 | + assert all(isinstance(r, pendulum.DateTime) for r in results) |
| 27 | + |
| 28 | + |
| 29 | +def test_duration_threaded(): |
| 30 | + def make_duration(): |
| 31 | + return pendulum.duration(years=1, months=2, days=3) |
| 32 | + |
| 33 | + results = _run_parallel(make_duration) |
| 34 | + assert all(r.years == 1 and r.months == 2 for r in results) |
| 35 | + |
| 36 | + |
| 37 | +def test_diff_threaded(): |
| 38 | + dt1 = pendulum.datetime(2024, 1, 1) |
| 39 | + dt2 = pendulum.datetime(2024, 6, 15) |
| 40 | + |
| 41 | + def compute_diff(): |
| 42 | + return dt1.diff(dt2) |
| 43 | + |
| 44 | + results = _run_parallel(compute_diff) |
| 45 | + expected = results[0] |
| 46 | + assert all(r.in_days() == expected.in_days() for r in results) |
| 47 | + |
| 48 | + |
| 49 | +def test_format_threaded(): |
| 50 | + dt = pendulum.datetime(2024, 1, 15, 10, 30, 0) |
| 51 | + |
| 52 | + def format_dt(): |
| 53 | + return dt.format("YYYY-MM-DD HH:mm:ss") |
| 54 | + |
| 55 | + results = _run_parallel(format_dt) |
| 56 | + assert all(r == "2024-01-15 10:30:00" for r in results) |
0 commit comments