What is the problem with Queue thread in Go's crawler Colly?
Go crawler Colly's request queue and thread concurrency: In-depth discussion
When using the Colly crawler library of Go, it is crucial to understand its request queue and thread concurrency mechanism. This article analyzes the interaction between the number of queue threads in Colly and the request delay, and answers "The question of Queue threads in Go crawler Colly?".
We use an example to illustrate: set the queue thread count to 2, use q, _ := queue.New(2, storage)
to create a queue, and add three requests. To observe the effect, set the Collector delay to 5 seconds. Intuitively, both requests should be issued almost at the same time and returned after 5 seconds; the third request is executed after 10 seconds.
However, the actual results are different:
- Two requests are created.
- After 5 seconds, the first request returns.
- The third request is created.
- After another 5 seconds, the second request returns.
- After another 5 seconds, the third request returns.
This shows that when Colly's Collector processes the request, it will consider the overall situation of the queue, but the delay of the request itself will affect the actual execution time. The number of queue threads limits the number of concurrent requests, but if the request is set, the delay will override the concurrent limit effect of the number of threads. Each request will be delayed by another 5 seconds after the previous request is completed, rather than being processed in real parallel.
Colly's OnRequest
callback function is fired when the request is created, not when the request is issued. It is mainly used for preprocessing before the request issuance, rather than controlling the time of the request issuance. The actual request issuance time is determined by the delay setting of the Collector.
Therefore, when the request is set to delay, the number of threads in the Colly queue has little impact on concurrency, and the order and time of the request are mainly controlled by the delay setting of the Collector. This helps to have a clearer understanding of Colly's queue mechanism and concurrency control.
The above is the detailed content of What is the problem with Queue thread in Go's crawler Colly?. For more information, please follow other related articles on the PHP Chinese website!

Hot AI Tools

Undresser.AI Undress
AI-powered app for creating realistic nude photos

AI Clothes Remover
Online AI tool for removing clothes from photos.

Undress AI Tool
Undress images for free

Clothoff.io
AI clothes remover

Video Face Swap
Swap faces in any video effortlessly with our completely free AI face swap tool!

Hot Article

Hot Tools

Notepad++7.3.1
Easy-to-use and free code editor

SublimeText3 Chinese version
Chinese version, very easy to use

Zend Studio 13.0.1
Powerful PHP integrated development environment

Dreamweaver CS6
Visual web development tools

SublimeText3 Mac version
God-level code editing software (SublimeText3)

Hot Topics











The problem of using RedisStream to implement message queues in Go language is using Go language and Redis...

Queue threading problem in Go crawler Colly explores the problem of using the Colly crawler library in Go language, developers often encounter problems with threads and request queues. �...

What should I do if the custom structure labels in GoLand are not displayed? When using GoLand for Go language development, many developers will encounter custom structure tags...

The difference between string printing in Go language: The difference in the effect of using Println and string() functions is in Go...

The library used for floating-point number operation in Go language introduces how to ensure the accuracy is...

Two ways to define structures in Go language: the difference between var and type keywords. When defining structures, Go language often sees two different ways of writing: First...

Which libraries in Go are developed by large companies or well-known open source projects? When programming in Go, developers often encounter some common needs, ...

When using sql.Open, why doesn’t the DSN report an error? In Go language, sql.Open...
