@petelin 说的有点问题, 并不是主线程等待子线程都完成在退出(那是 join 干的事), 而是 python 解释器保证 当没有活跃的进程之后才退出(所以主线程先退出, 子线程继续执行, 知道完成 python 进程退出是有可能的).

那么这段代码问题是, 主进程跑完之后, 所有子进程都被干掉了.无论你子进程在干什么, 直接被干掉.

所有需要在主进程加一段代码
pool.close()
pool.join()

这样看起来就完了, 主进程会等待子进程完成, 而子进程会等待线程完成

可是子进程不会等待线程完成, 所以
t.start()
t.join()

那么为什么子进程不会等待非守护线程结束呢??? 我去学习一个

@justou 后台线程作用是, 当主线程退出的时候, 不用管他们(那他们能欢快的在后台运行吗? 看进程, 进程都退出了,直接被干掉). 反而非后台进程, 主进程即使不 join, 退出之前也要等子线程结束.

所以还是要学习一个.

def handler(self): def handler(self): def handler(self): def handler(self): def handler(self): def handler(self): def handler(self): def handler(self): def handler(self): def handler(self): def handler(self): def handler(self): def handler(self): def handler(self):

浪费 绳命

时间的比较应该在同一个时区下. 还有 replace 有坑, 使用 tzc.localize 更好

In [24]: from datetime import datetime
...: from pytz import timezone
...: import pytz
...: tzc = timezone('PRC')
...: tzu = timezone('US/Hawaii')
...:
...: time = datetime.utcnow()
...:
...: print('C:'+time.replace(tzinfo=tzc).astimezone(tz=pytz.utc).strftime('%H'))
...: print('U:'+time.replace(tzinfo=tzu).astimezone(tz=pytz.utc).strftime('%H'))
...:
C:04
U:23

有一种比较猥琐的方法, 在加多 3 个列, b1, c1, d1, 建索引 (a, b1, c1, d1).... 然后不需要唯一索引的写的时候用随机, 需要的正常写业务数据,,,, (我是把 a 当做条件列了)

a['a'] 是个列表, str 的时候,就是那么打印的

''.join(a['a']) .........

算了我懒得吐槽了..... 两个方法都不一样. 为什么你会认为输出一定要一样?

@mm163 我举个例子吧, 如果有 100 万个 status 为 0 的记录, 有一条 stattus 为 1 的记录, 那么查找 status 为 1 的记录能不能直接命中呢? 如果能的话, 那性能提升就很明显.

乱码贴出来看看

In [73]: for k,g in groupby(aa, lambda x:x['id']):
...: tmp[k] = '|'.join([item['txt'] for item in list(g)]) + '|'

In [22]: for item in aa:
...: tmp[item['id']]= tmp.get(item['id'], '') + item['txt'] + '|'

@lolizeppelin 不行。

```
def run_with_limited_time(func, args, kwargs, time):
"""Runs a function with time limit
:param func: The function to run
:param args: The functions args, given as tuple
:param kwargs: The functions keywords, given as dict
:param time: The time limit in seconds
:return: True if the function ended successfully. False if it was terminated.
"""
def wrapper(queue, func, *args, **kwargs):
return queue.put(func(*args, **kwargs))
import multiprocessing
q = multiprocessing.Queue(maxsize=1)
func = functools.partial(wrapper, q, func)
p = Process(target=func, args=args, kwargs=kwargs)
p.start()
p.join(time)
if p.is_alive():
p.terminate()
raise TimeoutError('time out!')

return q.get_nowait()
```

看起来是最好的实现了

@HarveyDent 比如有一句 sleep(10), 这句话没法再被拆分了.

创建主题时描述错了,为看到的 v 友说声抱歉, Process 和 Thread 说的乱七八糟的, 已改正.

正好遇到类似的问题, 我发现写日志的时候, 多进程并没有出现问题, 原来写小于 PIPE_BUF 是原子的.

http://me.xrange.top/2017/mutiprocess_append_1_file.html

@jiage8866 你能帮我下一个吗？

小米 红米 Note4X 全网通版 4GB+64GB 浅蓝色 移动联通电信 4G 手机 ，蓝色的才有 https://item.jd.com/4325123.html#crumb-wrap