Thread Safety for Background Tasks | Dataford Interview Questions

What strategies do you use to ensure thread safety when performing background tasks?

Implement run_background_tasks(tasks, worker_count) to execute a dependency graph concurrently. Each task has an integer value, and its result is its value plus the results of all dependencies. Protect shared scheduler state, avoid holding locks during task computation, and return results in the original task order. Inputs contain a valid acyclic graph, unique task IDs, and no task computation failures.

tasks is a list of {id: string, dependencies: list[string], value: integer} objects. Return a list of integers.

Constraints

1 <= len(tasks) <= 100
1 <= worker_count <= 32
Task IDs are unique non-empty strings
Every dependency refers to an existing task
The dependency graph is acyclic
Each value is an integer

Function Signature

def run_background_tasks(tasks, worker_count):

Your question is Thread Safety for Background Tasks. Start with the requirements in the Question tab.

Run and submit as often as you like. When you're ready, talk me through your approach or go straight to the code.

Problem

What strategies do you use to ensure thread safety when performing background tasks?

tasks is a list of {id: string, dependencies: list[string], value: integer} objects. Return a list of integers.

Constraints

1 <= len(tasks) <= 100
1 <= worker_count <= 32
Task IDs are unique non-empty strings
Every dependency refers to an existing task
The dependency graph is acyclic
Each value is an integer

Function Signature

def run_background_tasks(tasks, worker_count):

Your question is Thread Safety for Background Tasks. Start with the requirements in the Question tab.

Run and submit as often as you like. When you're ready, talk me through your approach or go straight to the code.