iron.worker.WorkerRuntimeBarrier Class Reference

Public Member Functions
	__init__ (self, int initial_value=0)
	wait_for_value (self, int value)
	release_with_value (self, int value)

Public Attributes
	initial_value
	worker_locks

Protected Member Functions
	_add_worker_lock (self, lock)
	_set_barrier_value (self, int value)

Detailed Description

A barrier allowing individual workers to synchronize with the runtime sequence.

Constructor & Destructor Documentation

__init__()

iron.worker.WorkerRuntimeBarrier.__init__	(		self,
		int	initial_value = 0
	)

Member Function Documentation

_add_worker_lock()

iron.worker.WorkerRuntimeBarrier._add_worker_lock (   self,   lock  )

protected

Register an additional lock in the barrier.

_set_barrier_value()

iron.worker.WorkerRuntimeBarrier._set_barrier_value (   self, int  value  )

protected

Set the value of the barrier.

release_with_value()

iron.worker.WorkerRuntimeBarrier.release_with_value	(		self,
		int	value
	)

Release and decrement the barrier by `value` inside the core.

Args:
    value (int): The value to decrement by in Release.

wait_for_value()

iron.worker.WorkerRuntimeBarrier.wait_for_value	(		self,
		int	value
	)

Should be called from inside a core function.
Wait for the barrier to be set to `value`.

Args:
    value (int): The value to wait for.

Member Data Documentation

initial_value

iron.worker.WorkerRuntimeBarrier.initial_value

worker_locks

iron.worker.WorkerRuntimeBarrier.worker_locks

---

The documentation for this class was generated from the following file:

• iron/worker.py