[Назад] Содержание [Дальше]

Использование Simple DirectMedia Layer API

Потоки

Создание простого потока Создание потока делается через вызов функции SDL_CreateThread(). После успешного возврата из функции ваша функция теперь запущена одновременно с основным приложением в своем контексте задачи (стек, регистры и прочее) и может получать доступ к памяти и открытым файлам используемыми в основном приложении.

Совет: Второй аргумент для SDL_CreateThread() передается как параметр для  порожденного потока. Вы можете использовать его для передачи значений в стек или только как указатель на данные, которые будут использоваться в потоке.

Пример:

#include "SDL_thread.h"
 
int global_data = 0;
 
int thread_func(void *unused)
{
 int last_value = 0;
 
 while ( global_data != -1 ) {
 if ( global_data != last_value ) {
            printf("Data value changed to %d\n", global_data);
            last_value = global_data;
        }
        SDL_Delay(100);
    }
    printf("Thread quitting\n");
 return(0);
}
 
{
    SDL_Thread *thread;
 int i;
 
    thread = SDL_CreateThread(thread_func, NULL);
 if ( thread == NULL ) {
        fprintf(stderr, "Unable to create thread: %s\n", SDL_GetError());
        return;
    }
 
 for ( i=0; i<5; ++i ) {
        printf("Changing value to %d\n", i);
        global_data = i;
        SDL_Delay(1000);
    }
 
    printf("Signaling thread to quit\n");
    global_data = -1;
    SDL_WaitThread(thread, NULL);
}

Синхронизация доступа к ресурсу Вы можете предотвращать доступ к ресурсу более чем из одного потока с помощью создания семафора и получать доступ к ресурсу, окружая доступ вызовом блокировки (SDL_mutexP()) и разблокировки (SDL_mutexV()).

Совет: Любые данные, которые могут быть доступны более чем одному потоку одновременно, должны быть защищены семафорами.

Пример: 

#include "SDL_thread.h"
#include "SDL_mutex.h"
 
int potty = 0;
int gotta_go;
 
int thread_func(void *data)
{
    SDL_mutex *lock = (SDL_mutex *)data;
 int times_went;
 
    times_went = 0;
 while ( gotta_go ) {
        SDL_mutexP(lock);    /* Lock  the potty */
        ++potty;
        printf("Thread %d using the potty\n", SDL_ThreadID());
 if ( potty > 1 ) {
            printf("Uh oh, somebody else is using the potty!\n");
        }
        --potty;
        SDL_mutexV(lock);
        ++times_went;
    }
    printf("Yep\n");
 return(times_went);
}
 
{
 const int progeny = 5;
    SDL_Thread *kids[progeny];
    SDL_mutex  *lock;
 int i, lots;
 
 /* Create the synchronization lock */
    lock = SDL_CreateMutex();
 
    gotta_go = 1;
 for ( i=0; i<progeny; ++i ) {
        kids[i] = SDL_CreateThread(thread_func, lock);
    }
 
    SDL_Delay(5*1000);
    SDL_mutexP(lock);
    printf("Everybody done?\n");
    gotta_go = 0;
    SDL_mutexV(lock);
 
 for ( i=0; i<progeny; ++i ) {
        SDL_WaitThread(kids[i], &lots);
        printf("Thread %d used the potty %d times\n", i+1, lots);
 }
    SDL_DestroyMutex(lock);
}

[Назад] Содержание [Дальше]