Skip to main content

File-Based Queue, Scheduler, and Mutex Locker for Python (Windows, macOS, Linux)

Project description


🧩 SynGate: File-Based Queue, Scheduler, Batch Processor, and Mutex Locker for Python (Windows, macOS, Linux)

SynGate is a lightweight, cross-platform solution for managing access between multiple local Python processes or console scripts.
It serves as a queue manager, task scheduler, and mutex locker, all using the local file system as its only backend.
No threads, no networking, and no external services required.

Built on top of withopen for reliable and atomic file-based control.


✅ Features

SynGate provides mechanisms to:

  • 🚦 Queue tasks in order using session IDs
  • ⏲️ Delay or skip processes based on time freshness (pulse)
  • 🔐 Lock or block execution with "Active" tags
  • ✅ Signal readiness with "Done" tags
  • 🔒 Serve as a file-based mutex lock across terminals or scripts

Compatible with Windows, macOS, and Linux.


🔰 Basic Example: Run a Task When It Is Safe

from syngate import enter, done

if enter("my_task", pulse=15):
    run_expensive_job()
    done("my_task")

What this does:

  • enter() checks if it is safe to run based on timing and queue state
  • If safe, your task runs
  • done() marks it as completed so others can proceed

⚙️ Parameters and Behavior

🧠 pulse: Freshness Timeout

The pulse defines how long an "Active" tag is considered fresh. If a tag is older than the pulse, it is considered stale, allowing a new task to proceed.

enter("data_export", pulse=20)

In this example, no other task can enter this gate for 20 seconds unless done() is called earlier.


🔄 wait=True (default): Wait Your Turn

The process waits until it is allowed to proceed.

# Only one terminal trims logs; others wait
if enter("log_trim", pulse=10, wait=True):
    trim_logs()
    done("log_trim")

🕊 wait=False: Skip If Blocked

The process skips execution if the gate is held. This is useful when you want one console to handle the task, but skip silently if another process is already doing it.

# Multiple tabs open; only one should handle cleanup
if enter("log_trim", pulse=10, wait=False):
    trim_logs()
    done("log_trim")
else:
    print("Skipped. Another tab is already trimming.")

👁️ display=True: Show Status in Console

The display parameter controls whether status messages are printed to the console.

if enter("my_task", pulse=12, display=True):
    do_something()
    done("my_task")

You will see messages like:

🧩 SYNGATE | QUEUING 🟡 [12:01:04]
🧩 SYNGATE | DEQUEUE 🟢 [12:01:07]

To run silently, set display=False:

if enter("silent_task", pulse=10, display=False):
    run_silently()
    done("silent_task")

✅ Using done(): Signal Early Completion

By default, pulse controls how long others must wait. If your task finishes early, call done() to release the gate immediately.

if enter("fast_task", pulse=15):
    do_quick_thing()
    done("fast_task")  # Allow the next task to proceed without waiting 15 seconds

🔐 Using active(): Extend "I'm Busy" Signal

If your process is still working but has not re-entered the gate, use active() to manually signal that it is still in progress.

# Prevent others from starting while work is still ongoing
active("data_load", pulse=12)

This delays others from entering until the pulse expires, acting like a soft lock.


🧠 Use Cases

  • 🧪 Queueing batch tasks across Python scripts
  • 🔒 Mutex locking using only the file system
  • 🧼 Preventing overlapping jobs such as log trimming or backups
  • 🕰️ Controlling time-spaced executions, with optional waiting or skipping

🛠 Console Output Indicators

Icon Meaning
🔴 HOLDING. Waiting for a valid time window
🟡 QUEUING. Preparing to enter
🟢 DEQUEUE. Successfully entered the gate
FLYOVER. Skipped due to wait=False

These icons appear when display=True is enabled.


💡 Developer Note

I created this tool to manage multiple bots and scripts that needed to run in order or avoid conflicts, such as editing a shared log. The done() function sped things up when I did not want to wait, and active() allowed me to hold the gate when work was still ongoing. It is simple, fast, and avoids unnecessary complexity by using just the file system.


📜 License

All Rights Reserved — Permission Required

Copyright (c) 2025 [henry]

This software is provided for viewing and educational purposes only.

Any form of reuse, reproduction, modification, distribution, or inclusion in other projects or products (whether commercial or non-commercial) is strictly prohibited without the prior explicit written permission of the author.

This includes, but is not limited to:

  • Copying the source code into another project
  • Reposting the code online or in packages
  • Creating modified versions or forks
  • Using the code in commercial tools, scripts, or libraries

To request permission, contact: [osas2henry@gmail.com]

By viewing or downloading this code, you agree to these terms.


Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

syngate-4.0.1.tar.gz (52.6 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

syngate-4.0.1-py3-none-any.whl (57.2 kB view details)

Uploaded Python 3

File details

Details for the file syngate-4.0.1.tar.gz.

File metadata

  • Download URL: syngate-4.0.1.tar.gz
  • Upload date:
  • Size: 52.6 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.2.0 CPython/3.12.7

File hashes

Hashes for syngate-4.0.1.tar.gz
Algorithm Hash digest
SHA256 f1fe3f1a1ab613458cb32c0f02d930a06247940c47caabdb27b33d683cd2da8f
MD5 a525b99f3f42c9edee462d0ff89c3662
BLAKE2b-256 3c4205096e13651aaec6dfc56105779d90bce70facfadb6bc94bc515bc5def45

See more details on using hashes here.

File details

Details for the file syngate-4.0.1-py3-none-any.whl.

File metadata

  • Download URL: syngate-4.0.1-py3-none-any.whl
  • Upload date:
  • Size: 57.2 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.2.0 CPython/3.12.7

File hashes

Hashes for syngate-4.0.1-py3-none-any.whl
Algorithm Hash digest
SHA256 433eb2261804b0b87c1367db49a2c42869d0c965d22ebcc7354a31eee48565df
MD5 09e81ae72537f55c6b28035e48274587
BLAKE2b-256 a6439b49df46330728d374f778d57530936bd04f4d8d4941459106aa588b4e71

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page