cpython_multithreaded.md

CPython Threads GIL Test

@embed

import thread, time
import numpy

class A:
	def __init__(self, name):
		self.name  = name
		self.value = 0
		self.flag  = True
		self.number = 1.5
		self.array = numpy.array([1,2,3,4]).astype(int)

	def echo(self, s):
		print s

	def show_array(self):
		print self.array

	def run(self):
		print '-----starting run'
		while self.value < 10:
			print 'from cpython:', self.value
			self.value += 1
			time.sleep(0.1)
		print '------end run'
	def run_thread(self):
		thread.start_new_thread(self.run, ())

note: spawn creates a c++11 thread.

Build Options

• @link:python2.7
• @include:/usr/include/python2.7

#backend:c++
import cpython
from time import sleep

with pointers:
	def thread_runner(pyob:PyObject):
		print 'enter thread runner'
		with gil:
			pyob->run_thread()
			#pyob->run()
		print 'edit thread runner'


	def thread1( input: chan PyObject, output: chan PyObject ):
		while True:
			pyob = <- input  ## gets from main
			if pyob is None:
				print 'pyob is None'
				break
			with gil:
				v = pyob->value as int
			print 'thread1:', v
			sleep(0.5)

		#for i in range(100):
		#	v = pyob->value as int
		#	print 'thread1:', v
		#	#output <- pyob  ## sends to thread2
		print 'end thread1'

	def thread2( C: chan PyObject):
		for i in range(100):
			pyob = <- C
			v = pyob->value as int
			print 'thread2:', v


def main():
	thread_state = cpython.initalize()

	print 'setup channels'
	input  = channel(PyObject)
	output = channel(PyObject)

	with gil:
		a = cpython.A('xxx')
		x = 99
		a->value = PyInt_FromLong(x)
		a->value = 1
		for i in range(4):
			b = a->array[i] as int
			print 'numpy array data:', b
			a->array[i] = PyInt_FromLong(i*10)

		a->show_array()
		a->echo('hello world')
		name = a->name as string
		print 'name:', name
		n = a->number as float
		print 'number:', n
		n = a->number as f64
		print 'number:', n
		f = a->flag as bool
		print 'flag:', f

	print 'addr of a:', a

	print 'starting thread1'
	spawn( thread_runner(a) )

	spawn(
		thread1(input, output)
	)
	#spawn(
	#	thread2(output)
	#)

	#a->run()
	#a->run_thread()

	print 'sending pyob'
	while True:
		with gil:
			v = a->value as int

		if v==10:
			break
		print 'main:', v

		input <- a
	input <- None

	print 'finalize'
	cpython.finalize( thread_state )