sleep函数在linux中的用法 cpp代码示例

下面是一个简单的 C++ 代码示例，展示了如何在 Linux 中使用 `sleep()` 函数：

#include <iostream>
#include <unistd.h>

int main() {
    std::cout << "Start sleeping..." << std::endl;
    sleep(3); // 暂停 3 秒钟
    std::cout << "Wake up!" << std::endl;
    return 0;
}

在上面的示例中，程序会输出 "Start sleeping..."，然后调用 `sleep()` 函数暂停 3 秒钟。最后，程序会输出 "Wake up!"，并退出。输出结果如下：

Start sleeping...
Wake up!

需要注意的是，`sleep()` 函数的精度只能保证到秒级别，如果需要更高精度的等待，可以考虑使用 `nanosleep()` 函数。

相关问题

cpp sleep函数在linux中的用法

在 Linux 中，可以使用 `sleep()` 函数来使当前进程挂起指定的时间，代码示例如下：

#include <unistd.h>

int sleep(unsigned int seconds);

其中 `seconds` 参数表示需要挂起的时间，单位是秒。函数执行成功后，当前进程会被挂起指定的时间，然后恢复执行。

需要注意的是，`sleep()` 函数在挂起当前进程时会导致 CPU 资源浪费，因为在挂起期间，CPU 无法执行其他任务。因此，在实际应用中，应该尽可能使用基于事件的异步编程方式，而不是依赖 `sleep()` 函数来等待事件。

MQTT协议 示例代码

### MQTT 协议示例代码

#### Python 实现

对于Python而言，Paho-MQTT是一个非常流行的库用于实现MQTT协议。下面展示了一个简单的发布者和订阅者的例子。

##### 发布者代码：

import paho.mqtt.client as mqtt

client = mqtt.Client()
client.connect("broker.hivemq.com", 1883, 60)

client.publish("test/topic", "Hello World")

client.disconnect()

这段代码创建了一个新的MQTT客户端实例并尝试连接到指定的代理服务器[^1]。

##### 订阅者代码:

import paho.mqtt.client as mqtt


def on_connect(client, userdata, flags, rc):
    client.subscribe("test/topic")


def on_message(client, userdata, msg):
    print(msg.topic+" "+str(msg.payload))


client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message

client.connect("broker.hivemq.com", 1883, 60)

client.loop_forever()

此部分展示了如何设置回调函数来处理接收到的消息以及当成功连接至代理时自动订阅特定主题的方法。

#### C++ 实现

针对C++环境下的MQTT应用开发，可以采用Eclipse Paho提供的官方C++库。这里给出一段基于Linux系统的简易版发布消息程序片段。

#include <iostream>
#include "mqtt/async_client.h"

using namespace std;

int main() {
    const string serverURI = "tcp://broker.hivemq.com:1883";
    const string clientId = "PublisherSample";

    mqtt::async_client sampleClient(serverURI, clientId);

    try {
        cout << "Connecting to the broker..." << endl;
        sampleClient.connect()->wait();
        cout << "Connected." << endl;

        auto message = make_shared<mqtt::message>("Hello world!");
        sampleClient.publish("sample/test", *message)->wait();

        cout << "Message published." << endl;

        sampleClient.disconnect()->wait();
        cout << "Disconnected from the broker." << endl;
    } catch (...) {
        cerr << "Error occurred while trying to connect or publish a message.";
    }

    return 0;
}

上述代码实现了向`sample/test`这个主题发送一条测试性质的信息给定的主题，并最终安全断开了与代理之间的会话链接[^3]。

#### Java 实现

在Java环境中同样能够利用Paho所提供的API轻松完成对MQTT的支持。以下是适用于Windows/Linux平台的一个基础版本的例子——它负责监听来自某个具体主题的数据流更新通知。

import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.eclipse.paho.client.mqttv3.MqttClient;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;


public class Subscriber {

    public static void main(String[] args) throws MqttException{
        
        String topic        = "test/topic";
        String content      = "This is a test message";
        int qos             = 2;
        String broker       = "tcp://broker.hivemq.com:1883";
        String clientId     = "SubscriberSample";
        MemoryPersistence persistence = new MemoryPersistence();

        try {
            MqttClient sampleClient = new MqttClient(broker, clientId, persistence);
            
            MqttConnectOptions connOpts = new MqttConnectOptions();
            connOpts.setCleanSession(true);
            System.out.println("Connecting to broker: "+broker);
            sampleClient.connect(connOpts);
            System.out.println("Connected");

            sampleClient.setCallback(new MqttCallback(){
                @Override
                public void connectionLost(Throwable cause){
                    System.out.println("Connection lost");
                }
                
                @Override
                public void deliveryComplete(IMqttDeliveryToken token){
                    
                }
                
                @Override
                public void messageArrived(String topic, MqttMessage message)throws Exception{
                    System.out.println("Incoming message: "+new String(message.getPayload()));
                }
            });

            sampleClient.subscribe(topic,qos);
            Thread.sleep(5*60*1000); // Wait for messages
            
            sampleClient.disconnect();
            System.out.println("Disconnected");
        }catch(MqttException me){
            System.out.println("reason "+me.getReasonCode());
            System.out.println("msg "+me.getMessage());
            System.out.println("loc "+me.getLocalizedMessage());
            System.out.println("cause "+me.getCause());
            System.out.println("excep "+me);
            me.printStackTrace();
        }
    }
}

以上代码段定义了一名订阅者角色，通过设定回调接口的方式接收到来自目标主题的新消息推送事件的通知。