A concurrent variant to the standard Collection

Introduced properties

type REAL: Collection[E]

pthreads :: ConcurrentCollection :: REAL

Type of the equivalent non thread-safe collection
fun mutex: Mutex

pthreads :: ConcurrentCollection :: mutex

Mutex used to synchronize access to self
protected fun mutex=(mutex: Mutex)

pthreads :: ConcurrentCollection :: mutex=

Mutex used to synchronize access to self
fun real_collection: REAL

pthreads :: ConcurrentCollection :: real_collection

Collection wrapped by self
protected fun real_collection=(real_collection: REAL)

pthreads :: ConcurrentCollection :: real_collection=

Collection wrapped by self

Redefined properties

redef type SELF: ConcurrentCollection[E]

pthreads $ ConcurrentCollection :: SELF

Type of this instance, automatically specialized in every class
redef fun count(e: nullable Object): Int

pthreads $ ConcurrentCollection :: count

How many occurrences of item are in the collection?
redef fun first: E

pthreads $ ConcurrentCollection :: first

Return the first item of the collection
redef fun has(e: nullable Object): Bool

pthreads $ ConcurrentCollection :: has

Is item in the collection ?
redef fun has_all(e: Collection[nullable Object]): Bool

pthreads $ ConcurrentCollection :: has_all

Does the collection contain at least each element of other?
redef fun has_only(e: nullable Object): Bool

pthreads $ ConcurrentCollection :: has_only

Is the collection contain only item?
redef fun is_empty: Bool

pthreads $ ConcurrentCollection :: is_empty

Is there no item in the collection?
redef fun iterator: Iterator[E]

pthreads $ ConcurrentCollection :: iterator

Get a new iterator on the collection.
redef fun join(sep: nullable Text, last_sep: nullable Text): String

pthreads $ ConcurrentCollection :: join

Concatenate and separate each elements with separator.
redef fun length: Int

pthreads $ ConcurrentCollection :: length

Number of items in the collection.
redef fun rand: E

pthreads $ ConcurrentCollection :: rand

Return a random element form the collection
redef fun to_a: Array[E]

pthreads $ ConcurrentCollection :: to_a

Build a new array from a collection
redef fun to_s: String

pthreads $ ConcurrentCollection :: to_s

User readable representation of self.

All properties

fun !=(other: nullable Object): Bool

core :: Object :: !=

Have self and other different values?
fun ==(other: nullable Object): Bool

core :: Object :: ==

Have self and other the same value?
type CLASS: Class[SELF]

core :: Object :: CLASS

The type of the class of self.
type CONCURRENT: ConcurrentCollection[E]

core :: Collection :: CONCURRENT

Type of the concurrent variant of this collection
type REAL: Collection[E]

pthreads :: ConcurrentCollection :: REAL

Type of the equivalent non thread-safe collection
type SELF: Object

core :: Object :: SELF

Type of this instance, automatically specialized in every class
protected fun class_factory(name: String): CLASS

core :: Object :: class_factory

Implementation used by get_class to create the specific class.
fun class_name: String

core :: Object :: class_name

The class name of the object.
fun combinations(r: Int): Collection[SequenceRead[E]]

core :: Collection :: combinations

All r-length combinations on self (in same order) without repeated elements.
fun combinations_with_replacement(r: Int): Collection[SequenceRead[E]]

core :: Collection :: combinations_with_replacement

All r-length combination on self (in same order) with repeated elements.
fun count(item: nullable Object): Int

core :: Collection :: count

How many occurrences of item are in the collection?
fun first: E

core :: Collection :: first

Return the first item of the collection
fun get_class: CLASS

core :: Object :: get_class

The meta-object representing the dynamic type of self.
fun has(item: nullable Object): Bool

core :: Collection :: has

Is item in the collection ?
fun has_all(other: Collection[nullable Object]): Bool

core :: Collection :: has_all

Does the collection contain at least each element of other?
fun has_any(other: Collection[nullable Object]): Bool

core :: Collection :: has_any

Does the collection contain at least one element of other?
fun has_exactly(other: Collection[nullable Object]): Bool

core :: Collection :: has_exactly

Does the collection contain exactly all the elements of other?
fun has_only(item: nullable Object): Bool

core :: Collection :: has_only

Is the collection contain only item?
fun hash: Int

core :: Object :: hash

The hash code of the object.
init init

core :: Object :: init

fun inspect: String

core :: Object :: inspect

Developer readable representation of self.
protected fun inspect_head: String

core :: Object :: inspect_head

Return "CLASSNAME:#OBJECTID".
fun is_empty: Bool

core :: Collection :: is_empty

Is there no item in the collection?
intern fun is_same_instance(other: nullable Object): Bool

core :: Object :: is_same_instance

Return true if self and other are the same instance (i.e. same identity).
fun is_same_serialized(other: nullable Object): Bool

core :: Object :: is_same_serialized

Is self the same as other in a serialization context?
intern fun is_same_type(other: Object): Bool

core :: Object :: is_same_type

Return true if self and other have the same dynamic type.
abstract fun iterator: Iterator[E]

core :: Collection :: iterator

Get a new iterator on the collection.
fun join(separator: nullable Text, last_separator: nullable Text): String

core :: Collection :: join

Concatenate and separate each elements with separator.
fun length: Int

core :: Collection :: length

Number of items in the collection.
fun mutex: Mutex

pthreads :: ConcurrentCollection :: mutex

Mutex used to synchronize access to self
protected fun mutex=(mutex: Mutex)

pthreads :: ConcurrentCollection :: mutex=

Mutex used to synchronize access to self
fun not_empty: Bool

core :: Collection :: not_empty

Alias for not is_empty.
intern fun object_id: Int

core :: Object :: object_id

An internal hash code for the object based on its identity.
fun output

core :: Object :: output

Display self on stdout (debug only).
intern fun output_class_name

core :: Object :: output_class_name

Display class name on stdout (debug only).
fun permutations(r: Int): Collection[SequenceRead[E]]

core :: Collection :: permutations

All r-length permutations on self (all possible ordering) without repeated elements.
fun plain_to_s: String

core :: Collection :: plain_to_s

Concatenate elements without separators
fun product(r: Int): Collection[SequenceRead[E]]

core :: Collection :: product

Cartesian product, over r times self.
fun rand: E

core :: Collection :: rand

Return a random element form the collection
fun real_collection: REAL

pthreads :: ConcurrentCollection :: real_collection

Collection wrapped by self
protected fun real_collection=(real_collection: REAL)

pthreads :: ConcurrentCollection :: real_collection=

Collection wrapped by self
fun sample(length: Int): Array[E]

core :: Collection :: sample

Return a new array made of (at most) length elements randomly chosen.
fun serialization_hash: Int

core :: Object :: serialization_hash

Hash value use for serialization
intern fun sys: Sys

core :: Object :: sys

Return the global sys object, the only instance of the Sys class.
fun to_a: Array[E]

core :: Collection :: to_a

Build a new array from a collection
abstract fun to_concurrent: CONCURRENT

core :: Collection :: to_concurrent

Wraps self in a thread-safe collection
fun to_counter: Counter[E]

core :: Collection :: to_counter

Create and fill up a counter with the elements of `self.
fun to_curlslist: CURLSList

core :: Collection :: to_curlslist

Convert Collection[String] to CURLSList
abstract fun to_jvalue(env: JniEnv): JValue

core :: Object :: to_jvalue

fun to_s: String

core :: Object :: to_s

User readable representation of self.
fun to_shuffle: Array[E]

core :: Collection :: to_shuffle

Return a new array made of elements in a random order.
package_diagram pthreads::ConcurrentCollection ConcurrentCollection core::Collection Collection pthreads::ConcurrentCollection->core::Collection core::Object Object core::Collection->core::Object ...core::Object ... ...core::Object->core::Object pthreads::ConcurrentSequenceRead ConcurrentSequenceRead pthreads::ConcurrentSequenceRead->pthreads::ConcurrentCollection pthreads::ConcurrentSequence ConcurrentSequence pthreads::ConcurrentSequence->pthreads::ConcurrentSequenceRead pthreads::ConcurrentSequence... ... pthreads::ConcurrentSequence...->pthreads::ConcurrentSequence

Ancestors

interface Object

core :: Object

The root of the class hierarchy.

Parents

interface Collection[E: nullable Object]

core :: Collection

The root of the collection hierarchy.

Children

abstract class ConcurrentSequenceRead[E: nullable Object]

pthreads :: ConcurrentSequenceRead

A concurrent variant to the standard SequenceRead

Descendants

class BlockingQueue[E: nullable Object]

pthreads :: BlockingQueue

A Blocking queue implemented from a ConcurrentList
class ConcurrentArray[E: nullable Object]

pthreads :: ConcurrentArray

A concurrent variant to the standard Array
class ConcurrentList[E: nullable Object]

pthreads :: ConcurrentList

A concurrent variant to the standard List
abstract class ConcurrentSequence[E: nullable Object]

pthreads :: ConcurrentSequence

A concurrent variant to the standard Sequence
class Mailbox[E: nullable Object]

actors :: Mailbox

A Blocking queue implemented from a ConcurrentList
class ReverseBlockingQueue[E: nullable Object]

pthreads :: ReverseBlockingQueue

A collection which is_empty method blocks until it's empty

Class definitions

pthreads $ ConcurrentCollection
# A concurrent variant to the standard `Collection`
abstract class ConcurrentCollection[E]
	super Collection[E]

	# Type of the equivalent non thread-safe collection
	type REAL: Collection[E]

	# Collection wrapped by `self`
	var real_collection: REAL is noinit

	# `Mutex` used to synchronize access to `self`
	#
	# It is used by the implementation on each protected methods. It can also
	# be used externally to ensure that no other `Thread` modify this object.
	var mutex = new Mutex

	redef fun count(e)
	do
		mutex.lock
		var r = real_collection.count(e)
		mutex.unlock
		return r
	end

	redef fun first
	do
		mutex.lock
		var r = real_collection.first
		mutex.unlock
		return r
	end

	redef fun has(e)
	do
		mutex.lock
		var r = real_collection.has(e)
		mutex.unlock
		return r
	end

	redef fun has_all(e)
	do
		mutex.lock
		var r = real_collection.has_all(e)
		mutex.unlock
		return r
	end

	redef fun has_only(e)
	do
		mutex.lock
		var r = real_collection.has_only(e)
		mutex.unlock
		return r
	end

	redef fun is_empty
	do
		mutex.lock
		var r = real_collection.is_empty
		mutex.unlock
		return r
	end

	redef fun iterator
	do
		mutex.lock
		var r = real_collection.iterator
		mutex.unlock
		return r
	end

	redef fun length
	do
		mutex.lock
		var r = real_collection.length
		mutex.unlock
		return r
	end

	redef fun to_a
	do
		mutex.lock
		var r = real_collection.to_a
		mutex.unlock
		return r
	end

	redef fun rand
	do
		mutex.lock
		var r = real_collection.rand
		mutex.unlock
		return r
	end

	redef fun join(sep, last_sep)
	do
		mutex.lock
		var r = real_collection.join(sep, last_sep)
		mutex.unlock
		return r
	end

	redef fun to_s
	do
		mutex.lock
		var r = real_collection.to_s
		mutex.unlock
		return r
	end
end
lib/pthreads/concurrent_collections.nit:68,1--179,3