<div dir="ltr">Hi all,<div><br></div><div>I am getting a strange (for me) exception when i try to deepcopy/pickle channels that are still sending or receiving, as in:</div><div><br></div><div>--------------------------------------------------------------------------------------</div>
<div><br></div><div><div>import stackless, copy</div><div><br></div><div>class Test(object):</div><div>    def __init__(self):</div><div>        self.channel = stackless.channel()</div><div>        </div><div>    def run(self):</div>
<div>        stackless.tasklet(self.sender)()</div><div>        stackless.tasklet(self.receiver)()</div><div>        stackless.run()</div><div>        </div><div>    def sender(self):</div><div>        counter = 0</div><div>
        while counter < 10:</div><div>            self.channel.send(counter)</div><div>            counter += 1</div><div>        </div><div>    def receiver(self):</div><div>        counter = 0</div><div>        while counter < 12:</div>
<div>            counter = self.channel.receive()</div><div>            print counter,</div><div>        print "done"</div><div>            </div><div>if __name__ == "__main__":</div><div>    </div><div>
    t = Test()</div><div>    t.run()</div><div>    t.channel = None </div><div>    t = copy.deepcopy(t) #OK</div><div>    </div><div>    t = Test()</div><div>    t.run()</div><div>    t = copy.deepcopy(t) #ERROR</div></div>
<div><br></div><div><div><div>----------------------------------------------------------------------------------------------</div></div><div>the error is:</div><div><br></div><div>TypeError: object.__new__(NotImplementedType) is not safe, use NotImplementedType.__new__()<br>
</div><div><br></div><div>somewhere deep into deepcopy, after reading some forums, i think it's trying to copy a module.</div><div><div>----------------------------------------------------------------------------------------------</div>
</div><div><br></div><div>Probably a lack in my basic understanding of stackless: why is the line  t.channel = None reached if one of the tasklets is still waiting on a channel?</div><div><br></div><div>Anyway,in this case the receiver tasklet is still waiting while the sender is done, but it also happens if the receiever is done before the sender (e.g. change 12 to 8). There is no error if both are done at the same time (change 12 to 10).</div>
<div><br></div><div>Can someone explain this to me? Is it unavoidable or can it somehow be fixed. Otherwise i would probably need to clean up all channels after a stackless run is finished and create them before a run starts or do something similar in in __getstate__/__setstate__. I use the ??? pattern to allow external interuption the stackless run:</div>
<div><br></div><div><div>----------------------------------------------------------------------------------------------</div></div><div><br></div><div>class OpenTasklets(Tasklets):</div><div>    </div><div>    stop = False</div>
<div>        </div><div>    @classmethod</div><div>    def run(cls, maxcount = None):</div><div>        cls.schedule_channel = stackless.channel()</div><div>        cls.schedule_channel.preference = 1</div><div>        counter = 0</div>
<div>        while stackless.getruncount() != 1:</div><div>            stackless.run()</div><div>            cls.reschedule(cls.stop or (maxcount and counter > maxcount))</div><div>            counter += 1</div><div>      </div>
<div>    @classmethod</div><div>    def schedule(cls):</div><div>        if cls.schedule_channel.receive():</div><div>            raise TaskletExit</div><div>        </div><div>    @classmethod</div><div>    def reschedule(cls, stop = False):</div>
<div>        while cls.schedule_channel.balance < 0:</div><div>            cls.schedule_channel.send(stop)</div><div>            </div><div>    @classmethod</div><div>    def tasklet(cls, func):</div><div>        return stackless.tasklet(func)</div>
<div>----------------------------------------------------------------------------------------------</div><div>  </div><div>Cheers, Lars</div><div>-- </div>====================================<br>Lars van Gemerden<br><a href="mailto:lars@rational-it.com">lars@rational-it.com</a><br>
+31 6 26 88 55 39<br>====================================
</div></div>