mactec 最近的时间轴更新 mactec 最近的时间轴更新 |
mactecV2EX 第 218352 号会员，加入于 2017-03-02 10:28:32 +08:00 |
mactec 最近回复了
2020-10-11 11:48:19 +08:00 回复了 a719114136 创建的主题 › 分享创造 › YTask V2.2.0 发布， Go 语言异步任务框架 |
@a719114136 类似 machinery 的 chain，chord 任务
2020-10-10 10:37:34 +08:00 回复了 a719114136 创建的主题 › 分享创造 › YTask V2.2.0 发布， Go 语言异步任务框架 |
请教下
我比较关心像链式任务、回调、重试、超时这些是否完善，因为现在项目里较多相关场景
我比较关心像链式任务、回调、重试、超时这些是否完善，因为现在项目里较多相关场景
2019-06-30 15:01:17 +08:00 回复了 sanbenweiyang 创建的主题 › 推广 › [视频分享]适合学习 golang 非常不错的 tcp 服务器框架-(从 0 开始搭建) |
bWFjdGVjQDEyNi5jb20=
学习下录制视频经验
学习下录制视频经验
2019-06-04 17:55:15 +08:00 回复了 mactec 创建的主题 › 酷工作 › [字节跳动-北京] 招聘测试开发（实习、正式均有坑） |
@jaryoung 可以安排到周日的
2019-06-04 17:54:59 +08:00 回复了 mactec 创建的主题 › 酷工作 › [字节跳动-北京] 招聘测试开发（实习、正式均有坑） |
@meidada123 不限的，实习和正式都有坑，欢迎投递哈
2019-01-31 14:10:40 +08:00 回复了 Mohanson 创建的主题 › 程序员 › 用 Go 开发的一款网络加速器, 帮助你加速海外网络访问(不仅仅是吃鸡) |
mark 下，很棒
邮件了下楼主，git 上项目移除了，希望可以交流下
邮件了下楼主，git 上项目移除了，希望可以交流下
2017-09-02 17:13:01 +08:00 回复了 mactec 创建的主题 › Python › tornado 拿到 gen.return 异步返回的结果后，没有在 yield 的地方恢复继续执行 |
@bluesky139
'''
class Worker(object):
def __init__(self,str):
self._name = str
self._installed = False
def install(self):
if self._installed:
print "%s: no need to start again.worker has been installed!" % self._name
else:
self._installed = True
ioloop.IOLoop.instance().add_callback(self.test)
print "%s: worker is installed" % self._name
@gen.coroutine
def fetch(self,url):
req = HTTPRequest(url,connect_timeout=3,request_timeout=5)
client = httpclient.AsyncHTTPClient()
resp = yield gen.Task(client.fetch, req)
raise gen.Return(resp)
@gen.coroutine
def exact(self,resp):
yield gen.sleep(5)
raise gen.Return(10)
@gen.coroutine
def test(self):
if self._installed:
ioloop.IOLoop.instance().add_timeout(datetime.timedelta(microseconds=5000),self.test)
str = self._name
task_url = u'http://api.caipiao.163.com/missNumber_trend.html?gameEn=kuai3'
resp = yield self.fetch(task_url)
print "%s get resp already at %s" %(str,datetime.datetime.now())
staus = yield self.exact(resp)
print "callback!!!%s status returned %d at %s" %(str,staus,datetime.datetime.now())
if __name__ == '__main__':
arrs = ['aaa','bbb']
for arr in arrs:
worker = Worker(arr)
worker.install()
ioloop.IOLoop.instance().start()
'''
谢谢，还在找原因
请问 ioloop.IOLoop.instance().add_timeout(datetime.timedelta(microseconds=5000),self.test)
这个能让 test 方法定期执行么，测试结果这个间隔没有用
'''
class Worker(object):
def __init__(self,str):
self._name = str
self._installed = False
def install(self):
if self._installed:
print "%s: no need to start again.worker has been installed!" % self._name
else:
self._installed = True
ioloop.IOLoop.instance().add_callback(self.test)
print "%s: worker is installed" % self._name
@gen.coroutine
def fetch(self,url):
req = HTTPRequest(url,connect_timeout=3,request_timeout=5)
client = httpclient.AsyncHTTPClient()
resp = yield gen.Task(client.fetch, req)
raise gen.Return(resp)
@gen.coroutine
def exact(self,resp):
yield gen.sleep(5)
raise gen.Return(10)
@gen.coroutine
def test(self):
if self._installed:
ioloop.IOLoop.instance().add_timeout(datetime.timedelta(microseconds=5000),self.test)
str = self._name
task_url = u'http://api.caipiao.163.com/missNumber_trend.html?gameEn=kuai3'
resp = yield self.fetch(task_url)
print "%s get resp already at %s" %(str,datetime.datetime.now())
staus = yield self.exact(resp)
print "callback!!!%s status returned %d at %s" %(str,staus,datetime.datetime.now())
if __name__ == '__main__':
arrs = ['aaa','bbb']
for arr in arrs:
worker = Worker(arr)
worker.install()
ioloop.IOLoop.instance().start()
'''
谢谢，还在找原因
请问 ioloop.IOLoop.instance().add_timeout(datetime.timedelta(microseconds=5000),self.test)
这个能让 test 方法定期执行么，测试结果这个间隔没有用
2017-08-29 13:08:04 +08:00 回复了 mactec 创建的主题 › Python › tornado 拿到 gen.return 异步返回的结果后，没有在 yield 的地方恢复继续执行 |
mark 下，如果有答案了再来更新
2017-05-03 17:54:11 +08:00 回复了 woshixiaohao1982 创建的主题 › 问与答 › 口头 offer 有多大可能性被放鸽子 |
@woshixiaohao1982 恭喜恭喜，效率很高啊
2017-05-02 17:23:44 +08:00 回复了 woshixiaohao1982 创建的主题 › 问与答 › 口头 offer 有多大可能性被放鸽子 |
@lusheldon 这尴尬了。。我就是得到这样的回复，说 5 1 休假了。手里拖着其他 offer，快要给答复的期限了，最中意的又一直拖着，真是一报还一报啊。。
Select Language