Class: Concurrent::Cancellation

Inherits:
Synchronization::Object
  • Object
show all
Defined in:
lib/concurrent/edge/cancellation.rb

Overview

Provides tools for cooperative cancellation. Inspired by msdn.microsoft.com/en-us/library/dd537607(v=vs.110).aspx

Examples:

# Create new cancellation. `cancellation` is used for cancelling, `token` is passed down to
# tasks for cooperative cancellation
cancellation, token = Concurrent::Cancellation.create
Thread.new(token) do |token|
  # Count 1+1 (simulating some other meaningful work) repeatedly until the token is cancelled through
  # cancellation.
  token.loop_until_canceled { 1+1 }
end
sleep 0.1
cancellation.cancel # Stop the thread by cancelling

Defined Under Namespace

Classes: Token

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.create(resolvable_future_or_event = Promises.resolvable_event, *resolve_args) ⇒ Array(Cancellation, Cancellation::Token)

Creates the cancellation object. Returns both the cancellation and the token for convenience.

Examples:

cancellation, token = Concurrent::Cancellation.create

Parameters:

  • resolve_args (Object) —

    resolve_args Arguments which are used when resolve method is called on resolvable_future_or_event

  • resolvable_future_or_event (Promises::Resolvable) (defaults to: Promises.resolvable_event) —

    resolvable used to track cancellation. Can be retrieved by ‘token.to_future` ot `token.to_event`.

Returns:



27
28
29
30
 
# File 'lib/concurrent/edge/cancellation.rb', line 27

def self.create(resolvable_future_or_event = Promises.resolvable_event, *resolve_args)
  cancellation = new(resolvable_future_or_event, *resolve_args)
  [cancellation, cancellation.token]
end

Instance Method Details

#cancel(raise_on_repeated_call = true) ⇒ true, false

Cancel this cancellation. All executions depending on the token will cooperatively stop.

Returns:

  • (true, false)

Raises:

  • when cancelling for the second tim



43
44
45
 
# File 'lib/concurrent/edge/cancellation.rb', line 43

def cancel(raise_on_repeated_call = true)
  !!@Cancel.resolve(*@ResolveArgs, raise_on_repeated_call)
end

#canceled? ⇒ true, false

Is the cancellation cancelled?

Returns:

  • (true, false) 


49
50
51
 
# File 'lib/concurrent/edge/cancellation.rb', line 49

def canceled?
  @Cancel.resolved?
end

#to_s ⇒ String Also known as: inspect

Short string representation.

Returns:

  • (String) 


55
56
57
 
# File 'lib/concurrent/edge/cancellation.rb', line 55

def to_s
  format '<#%s:0x%x canceled:%s>', self.class, object_id << 1, canceled?
end

#token ⇒ Token

Returns the token associated with the cancellation.

Returns:



36
37
38
 
# File 'lib/concurrent/edge/cancellation.rb', line 36

def token
  @Token
end