推荐学习书目 Learn Python the Hard Way Python Sites PyPI - Python Package Index http://diveintopython.org/toc/index.html Pocoo 值得关注的项目 PyPy Celery Jinja2 Read the Docs gevent pyenv virtualenv Stackless Python Beautiful Soup 结巴中文分词 Green Unicorn Sentry Shovel Pyflakes pytest Python 编程 pep8 Checker Styles PEP 8 Google Python Style Guide Code Style from The Hitchhiker's Guide
这是一个创建于 2223 天前的主题，其中的信息可能已经有所发展或是发生改变。
我当前是使用 queue 单向队列；
我需要实现功能如下：
从数据库拉取数据，然后放入队列，然后多线程进行访问；
线程每次使用 queue.get 获取一条数据访问；结束业务的时候又把数据 put 到队尾；
一直循环；
我另外还有一个线程，一直监听一个接收事件，如果接收到数据，就往队列里插入数据；
那么问题来了，如果我想中间的时候往队列里增加数据 或者 删除数据怎么办？ 比如我想删除队列里的某一个数据，好像 queue 不支持从中间删除数据。
我这样的业务逻辑是不是不应该使用队列？
第 1 条附言 2019-09-17 10:30:04 +08:00
我的原始业务逻辑大概是：
我想有一个数组 或者 队列 一样存放数据的地方，我不想每次都查询数据库，所以把数据拉出来就放在这里面，暂且称之为 [池] ；
我要从池里拉取 url 进行访问，如果访问正常，则从新插到池最后，否则就丢弃，
然后我是多线程的，我害怕线程会取到同一条数据，所以用了队列的方式，毕竟 queue.get 可以避免线程取到同一条数据；
并且我有一个 redis 订阅，如果 redis 有新的数据了，我就把新的数据放入池里；
其实最终我并不是想用队列来实现，只是害怕线程会取到同样的数据，我才用了队列；
可是我发现队列并不能满足我的业务需求，比如往队列里删除指定数据；
所以各位，有什么高见；
我想有一个数组 或者 队列 一样存放数据的地方，我不想每次都查询数据库，所以把数据拉出来就放在这里面，暂且称之为 [池] ；
我要从池里拉取 url 进行访问，如果访问正常，则从新插到池最后，否则就丢弃，
然后我是多线程的，我害怕线程会取到同一条数据，所以用了队列的方式，毕竟 queue.get 可以避免线程取到同一条数据；
并且我有一个 redis 订阅，如果 redis 有新的数据了，我就把新的数据放入池里；
其实最终我并不是想用队列来实现，只是害怕线程会取到同样的数据，我才用了队列；
可是我发现队列并不能满足我的业务需求，比如往队列里删除指定数据；
所以各位，有什么高见；
 | 1 Amit 2019-09-16 14:44:40 +08:00 这里没看出来哪里一定需要队列，queue.get 每次获取一条数据，数据还有插入删除的操作，不如直接使用数据库实现一个链表，定时任务每次查询一条头部记录 |
 | 2 smallgoogle OP @Amit 因为不想每次都从数据库里拉数据，想第一次启动的时候就拉出数据放在队列，然后利用队列会锁住数据的功能，让多线程不会执行到同一条数据。 |
 | 3 speedofstephen 2019-09-16 14:55:24 +08:00 额 linkedlist 其实实现了 Queue |
 | 4 xstoop 2019-09-16 15:05:05 +08:00 感觉你的队列使用有问题，一般队列的消费者跟生产者是分开的 |
 | 5 Lax 2019-09-16 15:07:08 +08:00 “队列会锁住数据” ？？？这是个什么原理 |
| 6 smallgoogle OP @xstoop 我认为我使用队列是有问题的，但是应该使用啥，我就是不知道 = = |
| 7 smallgoogle OP @Lax 我想表达的是，我多线程的时候，他们不会取到同一条数据的意思。 = = |
 | 8 workspace 2019-09-16 16:17:38 +08:00 关键字 redis list pop |
| 9 workspace 2019-09-16 16:20:16 +08:00 另外可看下最近基于 redis 实现的一个简单队列： https://github.com/lgphone/delay-queue |
 | 10 tt67wq 2019-09-16 16:43:48 +08:00 redis zset 可以的，用分数来维持顺序 |
| 11 xstoop 2019-09-16 17:02:03 +08:00 @smallgoogle 抛开你说的队列，线程这些。你大概描述一下你要实现的业务需求是什么呢 |
 | 12 raysonlu 2019-09-16 19:17:33 +08:00 有点好奇你的业务，消费者每次消费完毕，都放回队列，然后又有一个生产者往队列塞东西，最后这个队列岂不是越滚越大？ BTW，插队这种不恶劣行为估计是做不了的，删除的话，你可以再维护一个删除名单表让每次消费队列的时候都查询一下。zset 可以维持顺序，但消费者只能是定时任务中运行了。 |
 | 13 alexzhu592 2019-09-16 19:25:09 +08:00 via Android @Lax 他应该是说的是阻塞 |
| 14 alexzhu592 2019-09-16 19:27:49 +08:00 via Android 你的业务不适合用队列，想其他办法吧 |
 | 15 hspeed18 2019-09-17 02:10:19 +08:00  1 为什么不说一下你的业务需求是什么，用队列的理由是什么？ |
 | 16 ziding 2019-09-17 09:21:27 +08:00 感觉你是用错了，如果有任务优先级的要求，你应该用优先队列，而不是普通队列。如果用普通队列，要求能够撤回某些消息，应该用业务补偿，回滚的方式进行处理，而不是中间取消掉某个任务。 |
 | 17 hellotime 2019-09-17 09:54:04 +08:00 还是抛出原始需求比较好 |
| 18 smallgoogle OP |
| 19 raysonlu 2019-09-17 10:45:37 +08:00 像你说的，存放数据的地方，是个池或者数组，可以满足你增删需求，然后处理数据是个队列，可以满足多线程需求，那么，池归池，队列归队列，再找一个单线程的方法，让池中的数据迅速流入队列不就好了？ |
| 20 hellotime 2019-09-17 11:04:58 +08:00 @smallgoogle 这哪是原始需求，你的原始需求应该类似是我想搞一个代理网站，逐个测试一下代理，如果代理不行了就遗弃，可以的就保存起来，待下次检测。原始需求指的是产品要啥功能，而不是你做为开发说你要个队列。。 |
| 21 hellotime 2019-09-17 11:07:33 +08:00 多线程好像也取不到同一条记录把。 |
 | 22 lazyfighter 2019-09-17 13:59:28 +08:00 你应该说需求，另外这样使用队列，不会 oom 吗 |
 | 23 movax21h 2019-09-17 17:09:02 +08:00 应该不需要列队吧？ 因为你的多线程其实根本不会对同一个数据进行读写操作。（没有这个业务需求） 简单点，如果有 4 个线程，把从数据库获取的 url，分成四份不就行了吗？ 最后处理完成之后，再合一起。 不要打架，好处都有啥。 |
 | 24 Zzzz07 2019-09-17 17:47:30 +08:00 我也有个类似的需求，当有新的数据加入时就删除队列，出队时队列为空就重新去数据库中查询添加到队列中 |
| 25 alexzhu592 2019-09-17 22:19:19 +08:00 其实你的需求就是要保证容器的并发安全，同时又增删操作，主要是查询，你就直接用 redis 就可以了 |
 | 26 jimrok 2019-09-17 23:02:45 +08:00 感觉是一个做爬虫的小白 |
 | 27 jiangbingo 2019-09-19 09:52:10 +08:00 K:V 映射的字典 pop 出 K-url，update V-数据 会有什么问题？ |
Select Language