🔍 Code Extractor

Search Components

Full-Text: Fast keyword matching | Semantic: AI-powered understanding of intent (finds similar concepts)

Search Results for "concurrency"

Found 26 matching component(s)

  • function create_task

    Creates and registers a new background task in a thread-safe manner by initializing its metadata in a shared dictionary with status tracking, progress information, and timestamps.

    File: /tf/active/vicechatdev/docchat/app.py

    task-management background-tasks thread-safe concurrency task-tracking

  • function update_task_progress

    Thread-safe function that updates the progress and timestamp of an active task identified by task_id in a shared dictionary.

    File: /tf/active/vicechatdev/docchat/app.py

    task-management progress-tracking thread-safe concurrency locking

  • function complete_task

    Updates the status of a task to 'completed' in a thread-safe manner, storing the result and completion timestamp.

    File: /tf/active/vicechatdev/docchat/app.py

    task-management threading concurrency state-management thread-safe

  • function fail_task_v1

    Marks a task as failed by updating its status, recording the error message, and setting the completion timestamp in a thread-safe manner.

    File: /tf/active/vicechatdev/docchat/app.py

    task-management error-handling thread-safe state-management concurrency

  • function get_task_status_v1

    Thread-safe function that retrieves the current status of a task from a shared dictionary using a task identifier.

    File: /tf/active/vicechatdev/docchat/app.py

    threading concurrency task-management status-tracking thread-safe

  • function clear_session_v1

    Clears all messages from a chat session identified by session_id, resets the session's updated timestamp, and persists the changes to disk in a thread-safe manner.

    File: /tf/active/vicechatdev/docchat/app.py

    session-management chat thread-safe persistence state-management

  • function run_with_timeout

    Executes a function with a specified timeout using threading, raising a TimeoutException if the function exceeds the time limit.

    File: /tf/active/vicechatdev/docchat/document_indexer.py

    timeout threading concurrency execution-control error-handling

  • function parse_arguments

    Parses command-line arguments for a contract validity analysis tool that processes FileCloud documents with configurable options for paths, concurrency, output, and file filtering.

    File: /tf/active/vicechatdev/contract_validity_analyzer/main.py

    cli argument-parsing command-line argparse configuration

  • function store_uploaded_document

    Stores uploaded document metadata and content in a thread-safe application state dictionary, organized by user email and document ID.

    File: /tf/active/vicechatdev/vice_ai/complex_app.py

    document-storage thread-safe file-upload state-management user-data

  • function get_user_uploaded_documents

    Retrieves all uploaded documents associated with a specific user from a thread-safe global application state dictionary.

    File: /tf/active/vicechatdev/vice_ai/complex_app.py

    document-management user-data thread-safe concurrency state-management

  • function remove_uploaded_document

    Removes a specific uploaded document from the application state for a given user, with thread-safe locking and automatic cleanup of empty user entries.

    File: /tf/active/vicechatdev/vice_ai/complex_app.py

    document-management state-management thread-safe deletion cleanup

  • function clear_user_uploaded_documents

    Removes all uploaded documents associated with a specific user from the application state in a thread-safe manner.

    File: /tf/active/vicechatdev/vice_ai/complex_app.py

    user-management document-cleanup thread-safe state-management memory-cleanup

  • function store_uploaded_document_v1

    Stores an uploaded document in a thread-safe global application state dictionary, organizing documents by user email and document ID with metadata including name, content, file type, and upload timestamp.

    File: /tf/active/vicechatdev/vice_ai/complex_app.py

    document-storage thread-safe file-upload user-data chat-context

  • function remove_uploaded_document_v1

    Removes a specific uploaded document from a user's document collection in the application state, with thread-safe locking and automatic cleanup of empty user entries.

    File: /tf/active/vicechatdev/vice_ai/complex_app.py

    document-management thread-safe state-management deletion cleanup

  • function create_document_v6

    Creates a new ComplexDocument instance with a unique UUID, stores it in application state with thread-safe locking, persists it to file, and logs the creation.

    File: /tf/active/vicechatdev/vice_ai/complex_app.py

    document-management factory-method thread-safe persistence uuid

  • function create_chat_session

    Creates a new chat session for a specific document section by generating a unique session ID, initializing a ChatSession object, storing it in application state with thread-safe locking, and persisting it to file.

    File: /tf/active/vicechatdev/vice_ai/complex_app.py

    chat session-management thread-safe uuid state-management

  • function create_task_v1

    Creates and registers a new background task entry in a thread-safe manner, initializing its status, progress, user information, and timestamps.

    File: /tf/active/vicechatdev/vice_ai/app.py

    task-management background-tasks thread-safe concurrency task-tracking

  • function complete_task_v1

    Thread-safe function that marks a task as completed by updating its status, storing the result, and recording the completion timestamp in a shared task dictionary.

    File: /tf/active/vicechatdev/vice_ai/app.py

    task-management threading concurrency state-management thread-safe

  • function fail_task

    Marks a task as failed by updating its status, recording the error message, and setting the completion timestamp in a thread-safe manner.

    File: /tf/active/vicechatdev/vice_ai/app.py

    task-management error-handling thread-safe concurrency state-management

  • function get_user_documents

    Thread-safe function that retrieves all documents associated with a specific user email from a global document storage dictionary.

    File: /tf/active/vicechatdev/vice_ai/app.py

    document-management thread-safe user-data flask concurrency

  • function remove_user_document

    Removes a specific document for a user by deleting the file from the filesystem and removing its metadata from the in-memory storage structure.

    File: /tf/active/vicechatdev/vice_ai/app.py

    document-management file-deletion thread-safe cleanup storage-management

  • class ExecutionGuard

    A guard mechanism that prevents recursive or repeated function calls by tracking active executions and enforcing cooldown periods between calls.

    File: /tf/active/vicechatdev/CDocs/__init__.py

    concurrency guard debounce rate-limiting recursion-prevention

  • function guard_execution

    A decorator factory that prevents rapid repeated execution of a function by enforcing a cooldown period between calls.

    File: /tf/active/vicechatdev/CDocs/__init__.py

    decorator rate-limiting throttling cooldown debounce

  • function get_next_document_number

    Atomically retrieves and increments the next sequential document number for a specific document type and department combination from a Neo4j graph database.

    File: /tf/active/vicechatdev/CDocs/db/db_operations.py

    document-management counter sequential-numbering neo4j graph-database

  • function async_execute

    Wraps and schedules async function execution in the appropriate event loop context, ensuring proper lock propagation and document context management for Bokeh/Panel applications.

    File: /tf/active/vicechatdev/patches/server.py

    async event-loop bokeh panel tornado

  • function unlocked

    A context manager that temporarily unlocks a Bokeh Document and dispatches ModelChangedEvents to all connected WebSocket clients during the context execution.

    File: /tf/active/vicechatdev/patches/server.py

    context-manager bokeh websocket event-dispatching document-management

Search Examples