Skip to content
Back to skills

Threaded Multi Gpu Inference

ASecurity

Run multiple LLM inference jobs in parallel using Python threads, each pinned to a separate GPU with staggered starts

  • 61 stars
  • 0 votes
  • 0 copies
  • 1 view
  • Added September 12, 2026
documentationpythongit

Security analysis

A100/100

Scanned September 12, 2026

npx -y skills add wenmin-wu/ds-skills --skill threaded-multi-gpu-inference --agent claude-code

Installs into .claude/skills of the current project.

Are you the author of Threaded Multi Gpu Inference?

Add the live security badge to your README. It updates with every re-scan.

Security grade badge for Threaded Multi Gpu Inference
[![Security: A — Skills Directory](https://www.skillsdirectory.com/api/skills/wenmin-wu-threaded-multi-gpu-inference/badge)](https://www.skillsdirectory.com/skills/wenmin-wu-threaded-multi-gpu-inference)

More formats (shields.io, HTML) on the badges page. Keep it an A: scan every change in CI with Pro.

Download with Pro
SKILL.md
---
name: llm-threaded-multi-gpu-inference
description: Run multiple LLM inference jobs in parallel using Python threads, each pinned to a separate GPU with staggered starts
domain: llm
---

# Threaded Multi-GPU Inference

## Overview

When you have multiple LLMs to run and multiple GPUs available, parallelize using Python threads with each model pinned to a dedicated GPU. Stagger thread starts by ~10 seconds to avoid simultaneous memory allocation spikes. Collect results into shared DataFrames. Cuts wall-clock time by N for N GPUs.

## Quick Start

```python
import threading
import time
import torch

def run_inference_on_gpu(model_path, gpu_id, data, output_dict, name):
    """Run LLM inference on a specific GPU."""
    device = f"cuda:{gpu_id}"
    model = load_model(model_path, device=device)
    tokenizer = load_tokenizer(model_path)
    
    results = []
    for batch in create_batches(data, batch_size=8):
        inputs = tokenizer(batch, return_tensors="pt", padding=True,
                          truncation=True).to(device)
        with torch.no_grad():
            outputs = model(**inputs)
        results.append(outputs.logits.cpu())
    
    output_dict[name] = torch.cat(results)

# Launch parallel inference
results = {}
gpu_assignments = [
    ("path/to/gemma", 0, "gemma"),
    ("path/to/qwen", 1, "qwen"),
]

threads = []
for model_path, gpu_id, name in gpu_assignments:
    t = threading.Thread(
        target=run_inference_on_gpu,
        args=(model_path, gpu_id, test_data, results, name)
    )
    threads.append(t)
    t.start()
    time.sleep(10)  # stagger to avoid OOM

for t in threads:
    t.join()
# results["gemma"], results["qwen"] now available
```

## Key Decisions

- **Threads not processes**: GIL releases during CUDA ops, so threads work fine for GPU inference
- **10s stagger**: prevents simultaneous model loading from exhausting CPU RAM
- **Pin per GPU**: each model gets a dedicated GPU — don't share GPUs between models
- **Shared dict**: thread-safe for writes to different keys; no lock needed

## References

- Source: [ensemble-gemma-qwen-deepseek](https://www.kaggle.com/code/kishanvavdara/ensemble-gemma-qwen-deepseek)
- Competition: MAP - Charting Student Math Misunderstandings

Attribution

Is this your skill, or is something wrong with this listing? Request removal or report an issue. Author removals are honored within 72 hours.

Comments

Loading comments…