opencog-atomspace / tests / atoms / parallel / threaded.scm

;
; threaded.scm
;
; Part of the unit test for ExecuteThreadedLink.
;
(use-modules (opencog))

(Inheritance (Concept "rock") (Concept "mineral"))
(Inheritance (Concept "flower") (Concept "plant"))
(Inheritance (Concept "cat") (Concept "animal"))

; Just two threads.
(define pexec
	(ExecuteThreaded
		(Set
			(Meet
				(TypedVariable (Variable "X") (Type 'Concept))
				(Inheritance (Variable "X") (Concept "mineral")))
			(Meet
				(TypedVariable (Variable "X") (Type 'Concept))
				(Inheritance (Variable "X") (Concept "plant"))))
	))

; (cog-execute! pexec)

; One-hundred things to do in two threads.
;
; This is set up so that each Query differs from all the others,
; and so each Query uses a different UnisetValue to report results.
; This avoids issues when the same Query/Meet is run in parallel:
; if several identical Queries run in different threads, they will
; both be using the same result ContainerValue. When one instance
; closes the container while the other is still adding to it, an
; exception will be thrown and everything will go haywire.
; Thus, we want each thread to run it's own unique Query.
;
(define pmany
	(ExecuteThreaded
		(Number 2)
		(Set
			(map
				(lambda (n)
					(Query
						(TypedVariable (Variable "X") (Type 'Concept))
						(Inheritance (Variable "X") (Concept "mineral"))
						(List (Number n) (Variable "X"))))
				(iota 50))
			(map
				(lambda (n)
					(Query
						(TypedVariable (Variable "X") (Type 'Concept))
						(Inheritance (Variable "X") (Concept "plant"))
						(List (Number n) (Variable "X"))))
				(iota 50))
	)))

; (cog-execute! pmany)