C++&Pythonマルチスレッドノート

#include 
#include 
#include 

#include 

using std::vector;

void* Proc(void* arg)
{
    pthread_t pthread = *(pthread_t *)arg;
    printf("this is thread %ld
", pthread);
}

int main(int argc, char** argv)
{
    if (argc != 2)
    {
        printf("usage:%s thread_num", argv[0]);
        return 1;
    }
    int thread_num = atoi(argv[1]);
    vector threads(thread_num);
    for (int i = 0; i < thread_num; ++i)
    {
        pthread_t pthread;
        pthread_create(&pthread, NULL, &Proc, &threads[i]);
        threads[i] = pthread;
    }
    for (vector::iterator it = threads.begin(); it != threads.end(); ++it)
    {
        pthread_join(*it, NULL);
    }
    return 0;
}

 #include 
 #include 
 #include 
 
 #include 
 #include 
 
 #include 
 
 using std::vector;
 using std::string;
 
 void Proc(int num, const string& str)
 {
     printf("this is thread %d, say %s
", num, str.c_str());
 }
 
 int main(int argc, char** argv)
 {
     if (argc != 2)
     {
         printf("usage:%s thread_num", argv[0]);
         return 1;
     }
     int thread_num = atoi(argv[1]);
     vector<:thread> threads;
     for (int i = 0; i < thread_num; ++i)
     {
         boost::thread* thread = new boost::thread(&Proc, i, "Hello World!");
         threads.push_back(thread);    
     }
     for (vector<:thread>::iterator it = threads.begin(); it != threads.end(); ++it)
     {
         (*it)->join();
     }
     return 0;
 }

 #include 
 #include 
 #include 
 
 #include 
 #include 
 
 #include 
 #include 
 
 using std::vector;
 using std::string;
 
 class Test
 {
 public:
     void Proc(int num, const string& str)
     {
         printf("this is thread %d, say %s
", num, str.c_str());
     }
 };
 
 int main(int argc, char** argv)
 {
     if (argc != 2)
     {
         printf("usage:%s thread_num", argv[0]);
         return 1;
     }
     int thread_num = atoi(argv[1]);
     vector<:thread> threads;
     for (int i = 0; i < thread_num; ++i)
     {
         Test* test = new Test();
         boost::thread* thread = new boost::thread(boost::bind(&Test::Proc, test, i, "Hello World!"));
         threads.push_back(thread);    
     }
     for (vector<:thread>::iterator it = threads.begin(); it != threads.end(); ++it)
     {
         (*it)->join();
     }
     return 0;
 }

import sys
import threading

def proc(num, str):
    print 'this is thread %d, say %s' % (num, str)

def start_threads(thread_num):
    threads = []
    for i in range(thread_num):
        thread = threading.Thread(target=proc, args=(i, "Hello World!"))
        threads.append(thread)
        thread.start()

    for thread in threads:
        thread.join()

if __name__ == '__main__':
    if len(sys.argv) != 2:
        print "usage:%s thread_num" % sys.argv[0]
        sys.exit(1)
    start_threads(int(sys.argv[1]))

import sys
from multiprocessing.dummy import Pool as ThreadPool

def proc(arg):
    num, str = arg
    print 'this is thread %d, say %s' % (num, str)

def start_threads(thread_num):
    pool = ThreadPool(thread_num)
    args = [(i, "Hello World!") for i in range(thread_num)]
    pool.map(proc, args)
    pool.close()
    pool.join()

if __name__ == '__main__':
    if len(sys.argv) != 2:
        print "usage:%s thread_num" % sys.argv[0]
        sys.exit(1)
    start_threads(int(sys.argv[1]))