`
mypyg
  • 浏览: 550870 次
  • 性别: Icon_minigender_1
  • 来自: 成都
社区版块
存档分类
最新评论

GSource 创建时各函数的用处

 
阅读更多
1.prepare:

    进入睡眠之前,在g_main_context_prepare里,mainloop调用所有Source的prepare函数,计算最小的timeout时间,该时间决定下一次睡眠的时间。

2.check:

    poll被唤醒后,在g_main_context_check里,mainloop调用所有Source的check函数,检查是否有Source已经准备好了。如果poll是由于错误或者超时等原因唤醒的,就不必进行dispatch了。

3.dispatch:

    当有Source准备好了,在g_main_context_dispatch里,mainloop调用所有Source的dispatch函数,去分发消息。

4.finalize:

    在Source被移出时,mainloop调用该函数去销毁Source。

    

实例验证:

    1.创建两个GSource,一个2秒醒一次,一个3秒醒一次。

   
#include <stdio.h>
    #include <stdlib.h>
    #include <stdarg.h>
    #include <string.h>

    #include <glib.h>

    typedef struct _DemoSource DemoSource;
    struct _DemoSource
    {
      GSource               source;
      int   interval;
      GTimeVal              last;
    };

    DemoSource *s1, *s2;
    const char* cur_source_name = NULL;

    static glong my_time_val_difference (const GTimeVal *compare, const GTimeVal *now)
    {
      return (compare->tv_sec - now->tv_sec) * 1000 + (compare->tv_usec - now->tv_usec) / 1000;
    }

    static const char* get_source_str( GSource* source_ )
    {
            if( (unsigned int)source_ == (unsigned int)s1 ) return "s1";
            else if( (unsigned int)source_ == (unsigned int)s2 ) return "s2";

            return "unkown";
    }

    static gboolean prepare_func( GSource *source_, gint *timeout )
    {
            DemoSource* source = (DemoSource*)source_;
            GTimeVal now, target;
            glong diff;

            cur_source_name = get_source_str( source_ );

            g_source_get_current_time( source_, &now );

            target = source->last;
            g_time_val_add( &target, source->interval );

            diff = my_time_val_difference( &now, &target );

            printf("-----%s Enter -----\n", __FUNCTION__);

            if( diff >= 0 )
            {
                    *timeout = 0;
                    printf( "Source %s need to dispatch right now. D:%d\n", cur_source_name, diff );
                    return TRUE;
            }
            else
            {
                    *timeout = -diff;
                    printf( "Source %s need to sleep %d ms.\n", cur_source_name, *timeout );
                    return FALSE;
            }
            printf("-----%s Exit-----\n", __FUNCTION__);
    }

    static gboolean check_func( GSource* source_ )
    {
            DemoSource* source = (DemoSource*)source_;
            GTimeVal now, target;
            glong diff;

            cur_source_name = get_source_str( source_ );

            g_source_get_current_time( source_, &now );

            target = source->last;
            g_time_val_add( &target, source->interval );

            diff = my_time_val_difference( &now, &target );

            printf("-----%s Enter -----\n", __FUNCTION__);
            if( diff >= 0 )
            {
                    printf("Yes. Source %s need to dispatch.\n", cur_source_name );
                    return TRUE;
            }
            else
            {
                    printf("No. Source %s want to sleep.\n", cur_source_name );
                    return FALSE;
            }
            printf("-----%s Exit-----\n", __FUNCTION__);
    }

    static gboolean dispatch_func(GSource *source_, GSourceFunc callback, gpointer user_data)
    {
            cur_source_name = get_source_str( source_ );
            printf("-----%s Enter -----\n", __FUNCTION__);
            DemoSource* source = (DemoSource*)source_;
            g_get_current_time( &source->last );
            printf("Source %s dispatched.\n", cur_source_name);
            printf("-----%s Exit-----\n", __FUNCTION__);
    }

    static void finalize_func( GSource* source_ )
    {
            cur_source_name = get_source_str( source_ );
            printf("-----%s Enter -----\n", __FUNCTION__);
            printf("Source %s finalized.\n", cur_source_name );
            printf("-----%s Exit-----\n", __FUNCTION__);
    }

    SourceFuncs source_funcs =
    {
            prepare_func,
            check_func,
            dispatch_func,
            finalize_func,
    };

    int main( int argc, char** argv )
    {
            GMainLoop* loop;

            loop = g_main_loop_new( NULL, TRUE );

            s1 = (DemoSource*)g_source_new( &source_funcs, sizeof(DemoSource) );
            s2 = (DemoSource*)g_source_new( &source_funcs, sizeof(DemoSource) );
            s1->interval = 2000*1000;               //ms
            s2->interval = 3000*1000;

            g_get_current_time( &s1->last );
            g_get_current_time( &s2->last );

            g_source_attach( (GSource*)s1, NULL );
            g_source_attach( (GSource*)s2, NULL );

            printf( "s1 addr:0x%x\n", (unsigned int)s1 );
            printf( "s2 addr:0x%x\n", (unsigned int)s2 );

            g_main_loop_run( loop );

            return 0;
    }


    2.编译后的输出结果:

    s1 addr:0x804ae98
    s2 addr:0x804b500
    -----prepare_func Enter -----
    Source s1 need to sleep 2000 ms.
    -----prepare_func Enter -----
    Source s2 need to sleep 3000 ms.


    -----check_func Enter -----
    Yes. Source s1 need to dispatch.
    -----check_func Enter -----
    No. Source s2 want to sleep.
    -----dispatch_func Enter -----
    Source s1 dispatched.
    -----dispatch_func Exit-----
    -----prepare_func Enter -----
    Source s1 need to sleep 2000 ms.
    -----prepare_func Enter -----
    Source s2 need to sleep 1000 ms.


    -----check_func Enter -----
    No. Source s1 want to sleep.
    -----check_func Enter -----
    Yes. Source s2 need to dispatch.
    -----dispatch_func Enter -----
    Source s2 dispatched.
    -----dispatch_func Exit-----
    -----prepare_func Enter -----
    Source s1 need to sleep 1000 ms.
    -----prepare_func Enter -----
    Source s2 need to sleep 3000 ms.

    

    -----check_func Enter -----
    Yes. Source s1 need to dispatch.
    -----check_func Enter -----
    No. Source s2 want to sleep.
    -----dispatch_func Enter -----
    Source s1 dispatched.
    -----dispatch_func Exit-----
    -----prepare_func Enter -----
    Source s1 need to sleep 2000 ms.
    -----prepare_func Enter -----
    Source s2 need to sleep 2000 ms.

    3.结果分析:

       (1)首先2个source的prepare函数被调用。一个要呼2秒,一个要呼3秒

       (2)2秒后2个source的check函数被调用。s1确实是要dispatch,s2回答不关我事,不要叫我

       (3)s1被dispatch。

       (4)两个source的prepare函数再次调用。一个要呼2秒,一个再继续呼1秒

       (5)再次check

       (6)再次dispatch。

        循环往复

    4.个人理解:

       mainloop相当于管家,先问下(prepare())诸位大概什么时候用餐(dispatch())。统计后就设一个闹钟,到时提醒。但是由于没记下各自的时间,所以让大家再确认一下是不是自己(check()),如果check返回true,那么就被dispatch()了。

       或者由于外界事件,比如冰淇淋在大家呼呼的过程中送来了,管家就叫大家check()一下。虽然没到时间,但是如果check()返回true,那么也直接dispatch()了

分享到:
评论

相关推荐

    VSTO创建EXCEL自定义函数

    在VSTO中如何利用C#创建EXCEL自定义函数

    C++创建多层文件夹函数

    封装好的自动创建多层文件夹函数: // 如此调用,则会在C:\123目录下创建名为111的文件夹,111文件夹下又自动创建222,依次类推 CreateMultilFolder("C:\123", "111/222/333")

    Linux平台下创建和使用用户函数库.pdf

    "Linux平台下创建和使用用户函数库" Linux 平台下创建和使用用户函数库是指在 Linux 操作系统下创建和使用用户定义的函数库。函数库是一种预编译的代码集合,包含了一个或多个函数,可以在不同的应用程序中被调用和...

    MATLAB中创建自定义绘图函数的全面指南

    在MATLAB中,自定义绘图函数是一种强大的工具,它允许用户根据自己的需求创建特定的图形和可视化效果。这些函数可以封装复杂的绘图逻辑,使得绘图过程更加高效和可重复使用。本文将详细介绍如何在MATLAB中创建自定义...

    python 实现使用lambda来创建匿名函数

    # 题目:使用lambda来创建匿名函数。

    创建有导出函数的内核驱动程序

    本篇将详细探讨如何创建一个具有导出函数的内核驱动程序,以及涉及的相关知识点。 一、驱动程序的结构与功能 驱动程序通常包含初始化、设备控制、中断处理和清理等核心功能。在添加导出函数后,这些功能可以被用户...

    Hook函数CreateMutexA拦截互斥体创建

    在这个场景中,我们关注的是`CreateMutexA`函数的钩子,这是一个用于创建互斥体(Mutex)的API。互斥体是多线程编程中一个重要的同步对象,它确保同一时间只有一个线程可以访问共享资源。 `CreateMutexA`是Windows ...

    MySQL数据库:存储函数调用.pptx

    存储函数创建完后,就如同系统提供的内置函数(如VERSION()),所以调用存储函数的方法也差不多,都是使用SELECT关键字。 【例】 创建一个存储函数,返回Book表中某本书的作者姓名。 存储函数举例 DELIMITER $$ ...

    mfc下实现回调函数

    在Microsoft Foundation Classes (MFC) 中,回调函数是一种特殊类型的函数,它允许用户代码与库或操作系统进行交互,尤其是在处理异步事件时。回调函数通常作为参数传递给其他函数,以便在特定事件发生时调用。在MFC...

    Oracle 11gR2创建PASSWORD_VERIFY_FUNCTION对应密码复杂度验证函数步骤.doc

    例如,你可以创建一个名为`资源文件名`的配置,设置`FAILED_LOGIN_ATTEMPTS`为10,`PASSWORD_LIFE_TIME`为180天,并且使用`PASSWORD_VERIFY_FUNCTION`指定我们即将创建的验证函数`verify_function_11G`。 ```sql ...

    MySQL数据库:存储函数的创建.pptx

    MySQL数据库:存储函数的创建.pptx

    构造、析构函数

    构造函数的主要作用是在创建对象时初始化该对象。构造函数可以重载,这意味着一个类中可以有多个构造函数,只要它们的参数列表不同即可。 例如,考虑`Location`类,它定义了三个构造函数:无参构造函数、一个接受...

    postgresql 实现c language外部函数调用

    在PostgreSQL中,有时需要利用C语言来编写高性能或安全的关键功能,这可以通过创建外部函数实现。本教程将详细介绍如何在PostgreSQL中实现C语言外部函数的调用,包括环境配置、源代码编写、编译、创建函数以及测试...

    Oracle自定义聚合函数-分析函数

    在创建自定义聚合函数时,还需要定义一个对象类型(Object Type),这个对象类型将包含四个 ODCIAggregate 接口函数的实现。然后,使用 CREATE FUNCTION 语句来创建自定义的聚合函数。 例如,以下是一个简单的...

    02-31-上机:创建并调用函数.pdf

    在本篇上机练习中,我们将探讨Python编程中的核心概念——创建和调用函数,这是程序设计中的基本技能。函数是可重复使用的代码块,能够提高代码的复用性和模块化,使得程序更加清晰和易于维护。在此,我们将会通过两...

    使用S函数创建模型并调试

    本篇将深入探讨如何使用S函数创建模型,并对其进行调试。 首先,我们要了解什么是S函数。S函数是Simulink中的特殊组件,它允许用户用MATLAB或C/C++语言编写自己的系统级模型。这些函数可以是连续的、离散的、混合的...

    学学Python_31函数_创建函数01

    在"学学Python_31函数_创建函数01"的主题中,我们主要关注如何在Python中创建自定义函数。这通常是通过使用`def`关键字来实现的。 创建函数的基本语法如下: ```python def function_name(parameters): # 函数体 ...

    ArcGIS教程:经验半变异函数

    在创建经验半变异函数时,我们需要注意计算局限性,特别是当输入数据集的观测值数大于 5000 时,Geostatistical Analyst 将为结构分析和半变异函数模型拟合随机选择 5000 个观测值。这可能会影响模型的估计结果。 ...

    C++ 线程函数是类的成员函数

    由于成员函数需要对象实例才能被调用,因此在创建线程时需要提供对象的引用或指针。 ```cpp MyClass obj; std::thread my_thread(&MyClass::threadFunction, &obj, 42); // 42 是传递给成员函数的参数 ``` 三、...

    C/C++/Linux函数函数插桩(打桩)指南

    这种方法不需要改动原始库的源码,而是创建一个包含包装函数的新动态库,并在运行时优先加载这个库。 2.3 执行阶段插桩 执行阶段插桩,也称为运行时插桩,通常涉及使用工具(如gdb、valgrind等)或编写自定义的调试...

Global site tag (gtag.js) - Google Analytics