Функция класса и потоки

Если функцию Init сделать статической, это как-то повлияет на логику приложения?

>от void *arg, типа char *a,int b...

а чем указатель на структуру не подходит?

ой...не о том я видать:)

ну все-таки скорее где-то так:

class thread {
public :
    // Must be implemented by real client
    virtual void *run() = 0;

    int start() {
        int err = pthread_create(&pth_, 0, real_run, this);
        if (err) {
            // Handle failure
        }
    }

private :
    pthread_t pth_;

    static void * real_run(void *arg) {
        thread *t = arg;
        return t->run();
    }
};

// wbr

ps: если псевдокод не помогает, внизу рабочий пример

--- cut ---

#include <iostream>
#include <pthread.h>

class base_thread {
public :
    virtual ~base_thread() {}

    // Must be implemented by real client
    virtual void *run() = 0;

    int start() {
        return ::pthread_create(&pth_, 0, real_run, this);
    }

    pthread_t id() const {
        return pth_;
    }

private :
    pthread_t pth_;

    static void * real_run(void *arg) {
        base_thread *t = static_cast<base_thread *>(arg);
        return t->run();
    }
};

class my_thread : public base_thread {
public :
    void *run() {
        std::cout << "Run my thread!" << std::endl;
        return 0;
    }
};

int
main(int argc, char *argv[])
{
    my_thread t;

    std::cout << "Start thread" << std::endl;
    t.start();
    ::pthread_join(t.id(), 0);
    std::cout << "Done thread" << std::endl;

    return 0;
}
--- cut ---

foo@ip-230$ g++ -Wall -o foo foo.cc -lpthread
foo@ip-230$ ./foo
Start thread
Run my thread!
Done thread

// wbr

А можно пояснить сокральный смысл вызова вот этой функции?!

   ::pthread_join(t.id(), 0);

и два двоеточия в начале это опечатка или то же имеет смысл?

> А можно пояснить сокральный смысл вызова вот этой функции?!
>   ::pthread_join(t.id(), 0);

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

http://www.opengroup.org/onlinepubs/009695399/functions/pthread_join.html

> и два двоеточия в начале это опечатка или то же имеет смысл?

ну почему же опечатка, это явное указание на то, что функция
pthread_join() равно как и pthread_create() находятся в глобальном
пространстве имен бо в общем случае они могут быть перекрыты методами
класса, using namespace или еще какой херней. например:

--- cut ---
#include <iostream>

void
fnc()
{
    std::cout << "Global fnc" << std::endl;
}

class foo {
public :
    void fnc() {
        std::cout << "Class fnc" << std::endl;
    }
    void test() {
        fnc();
        ::fnc();
    }
};

int
main(int argc, char *argv[])
{
    foo f;
    f.test();
    return 0;
}
--- cut ---

foo@ip-230$ g++ -Wall -o foo foo.cc
Press any key to continue...
foo@ip-230$ ./foo
Class fnc
Global fnc

называется "почувствуй разницу". как следствие, если вы явным образом
обращаетесь к функции из глобального пространства имен, это лучше
всего не забывать указывать через пустое имя "::". иначе могут быть
проблемы.

// wbr

Понятно, большое человеческое спасибо! :)

Спасибо, мне тоже было интересно почитать =)

кстати а можно ::pthread_join(...) какнибудь засунуть внутрь класса base_thread ну или в my_thread?

ну возьмите да засуньте, в чем проблемы? никто не запрещает. только все-таки в base_thread а не my_thread бо последний нужен лишь для того, чтобы реализовать метод абстрактный run(). ну например:

--- cut ---
class base_thread {
public :
    virtual ~base_thread() {}

    // Must be implemented by real client
    virtual void *run() = 0;

    int start() {
        return ::pthread_create(&pth_, 0, real_run, this);
    }
    void wait() {
        ::pthread_join(pth_, 0);
    }

private :
    pthread_t pth_;

    static void * real_run(void *arg) {
        base_thread *t = static_cast<base_thread *>(arg);
        return t->run();
    }
};
--- cut ---

// wbr

Ну в этом варианте как я понял надо вызывать этот wait самому, а можно что бы это вызывалось из start()

пробовал добавить это в start но не прокатывало

    int start() {
        int n = ::pthread_create(&pth_, 0, real_run, this);
        ::pthread_join(pth_, 0);
        return n;
    }

"не прокатывало" - это значит не компилируется чтоль ? =)

повторю предыдущего оратора, pthread_join _усыпляет вызывающий_ поток до тех пор пока не завершится указанный (pth_)

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

ps: кстати - не вздумайте засунуть start() в этом виде в конструктор :)

не прокатывало, значит, поток не запускался, а прога сразу завершалась...

всё получилось, если исплоьзовать detach вместо join