curl_multi_exec - PHP code example

The php Function Curl_Multi_Exec

php function curl_multi_exec is an interface to libcurl-multi, which allows multiple cURL sessions to be executed simultaneously. This is a useful tool for doing things like scraping web pages, downloading files from servers, or executing API calls. It’s important to note that this function doesn’t return a response until all the parallel requests have finished, so you need to check on the status of each handle separately.

You can call curl_multi_exec() with an array of urls and some options, and it will create a stack of cURL handles for each request, processing them asynchronously. When all the individual requests have been processed, this function will return a CURLM_OK status. This is an integer that represents how many of the individual cURL requests have been completed, so you can use it to determine whether all of the requests are finished or not.

This example makes three GET requests in parallel to a server, and checks the status of each one. It takes a variable amount of time to complete each request, and the final result is displayed on the screen.

CURL is a powerful library in PHP that lets you engage with external services and APIs, making it a popular choice for automating tasks that require data transfer. The php function curl_multi_exec makes it easier than ever to execute multiple cURL requests at once. In this article, we’ll look at the different ways you can use this function and its variants to perform a variety of tasks.

curl_multi_exec example

        // Step through the task queue which may add additional requests.         P\Utils::queue()->run();

        if ($this->active && \curl_multi_select($this->_mh, $this->selectTimeout) === -1) {
            // Perform a usleep if a select returns -1.             // See: https://bugs.php.net/bug.php?id=61141             \usleep(250);
        }

        while (\curl_multi_exec($this->_mh, $this->active) === \CURLM_CALL_MULTI_PERFORM) {
        }

        $this->processMessages();
    }

    /** * Runs until all outstanding connections have completed. */
    public function execute(): void
    {
        $queue = P\Utils::queue();

$multi->handlesActivity[(int) $response->handle][] = null;
                $multi->handlesActivity[(int) $response->handle][] = new TransportException(sprintf('Userland callback cannot use the client nor the response while processing "%s".', curl_getinfo($response->handle, \CURLINFO_EFFECTIVE_URL)));
            }

            return;
        }

        try {
            $multi->performing = true;
            ++$multi->execCounter;
            $active = 0;
            while (\CURLM_CALL_MULTI_PERFORM === ($err = curl_multi_exec($multi->handle, $active))) {
            }

            if (\CURLM_OK !== $err) {
                throw new TransportException(curl_multi_strerror($err));
            }

            while ($info = curl_multi_info_read($multi->handle)) {
                if (\CURLMSG_DONE !== $info['msg']) {
                    continue;
                }
                $result = $info['result'];

return $pushedResponse ?? new CurlResponse($this->multi, $ch, $options, $this->logger, $method, self::createRedirectResolver($options, $host, $port), CurlClientState::$curlVersion['version_number'], $url);
    }

    public function stream(ResponseInterface|iterable $responses, float $timeout = null): ResponseStreamInterface
    {
        if ($responses instanceof CurlResponse) {
            $responses = [$responses];
        }

        if ($this->multi->handle instanceof \CurlMultiHandle) {
            $active = 0;
            while (\CURLM_CALL_MULTI_PERFORM === curl_multi_exec($this->multi->handle, $active)) {
            }
        }

        return new ResponseStream(CurlResponse::stream($responses, $timeout));
    }

    public function reset(): void
    {
        $this->multi->reset();
    }

$completed       = 0;
        $responses       = [];
        $subrequestcount = count($subrequests);

        $request['options']['hooks']->dispatch('curl.before_multi_exec', [&$multihandle]);

        do {
            $active = 0;

            do {
                $status = curl_multi_exec($multihandle, $active);
            } while ($status === CURLM_CALL_MULTI_PERFORM);

            $to_process = [];

            // Read the information as needed             while ($done = curl_multi_info_read($multihandle)) {
                $key = array_search($done['handle'], $subhandles, true);
                if (!isset($to_process[$key])) {
                    $to_process[$key] = $done;
                }
            }