擅长:python、mysql、java
<p>这笔交易的最终解决方案。。</p>
<pre><code>import os, sys, time
from twisted.internet import protocol, reactor
import itertools
def sendScenario(self):
def sendelayed(d):
self.sendata(d)
self.factory.out_dump.write(d)
try:
timeout, data = next(self.sc)
reactor.callLater(timeout, sendelayed, data)
except StopIteration:
print "Scenario completed!"
self.transport.loseConnection()
self.scenario = [(1, "Message after 1 sec!"), (4, "This after 4 secs"), (2, "End final after 2 secs")]
self.sc = iter(self.scenario)
timeout, data = next(self.sc)
reactor.callLater(timeout, sendelayed, data)
</code></pre>