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, fibers, and async tasks.

Instance Attribute Summary

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

Instance Method Summary

• #alive? ⇒ Boolean
• #initialize(task, function = nil) ⇒ LLM::Function::Task constructor
• #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 20

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

Instance Attribute Details

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

Returns:

• (LLM::Function, nil)

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

def function
  @function
end

#task ⇒ Object (readonly)

Returns:

• (Object)

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

def task
  @task
end

Instance Method Details

#alive? ⇒ Boolean

Returns:

• (Boolean)

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

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

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

Returns:

• (LLM::Function::Return)

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

def wait
  if Thread === task
    task.value
  elsif Fiber === task
    task.resume if task.alive?
    task.value
  else
    task.wait
  end
end