Class: LLM::Function::Task

Inherits:

Object

• Object
• LLM::Function::Task

Defined in:

lib/llm/function/task.rb

Overview

The Task class wraps a single concurrent function call and provides a small, uniform interface across threads, scheduler-backed fibers, and async tasks.

Instance Attribute Summary

• #task ⇒ Object readonly
• #function ⇒ LLM::Function^? readonly

Instance Method Summary

• #initialize(task, function = nil) ⇒ LLM::Function::Task constructor
• #alive? ⇒ Boolean
• #interrupt! ⇒ nil (also: #cancel!)
• #wait ⇒ LLM::Function::Return (also: #value)

Constructor Details

#initialize(task, function = nil) ⇒ LLM::Function::Task

Parameters:

• task (Thread, Fiber, Async::Task, Ractor, LLM::Function::Ractor::Task)
• function (LLM::Function, nil) (defaults to: nil)

# File 'lib/llm/function/task.rb', line 21

def initialize(task, function = nil)
  @task = task
  @function = function
end

Instance Attribute Details

#task ⇒ Object (readonly)

Returns:

• (Object)

# File 'lib/llm/function/task.rb', line 11

def task
  @task
end

#function ⇒ LLM::Function^? (readonly)

Returns:

• (LLM::Function, nil)

# File 'lib/llm/function/task.rb', line 15

def function
  @function
end

Instance Method Details

#alive? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/llm/function/task.rb', line 28

def alive?
  return task.alive? if task.respond_to?(:alive?)
  false
end

#interrupt! ⇒ nil Also known as: cancel!

Returns:

• (nil)

# File 'lib/llm/function/task.rb', line 35

def interrupt!
  function&.interrupt!
  nil
end

#wait ⇒ LLM::Function::Return Also known as: value

Returns:

• (LLM::Function::Return)

# File 'lib/llm/function/task.rb', line 43

def wait
  if Thread === task
    task.value
  elsif Fiber === task
    fiber.alive? ? scheduler.run : nil
    task.value
  else
    task.wait
  end
end