Changeset 18748

Timestamp:

Jul 25, 2008, 5:47:14 PM (18 years ago)

Author:

eugene

Message:

add pswarpThreadLauncher

Location:

branches/eam_branch_20080719/pswarp/src

Files:

• Makefile.am (modified) (1 diff)
• pswarp.c (modified) (1 diff)
• pswarp.h (modified) (1 diff)

branches/eam_branch_20080719/pswarp/src/Makefile.am

@@ -17 +17 @@
         pswarpSetMaskBits.c             \
         pswarpTransformReadout_Opt.c    \
+        pswarpThreadLauncher.c          \
         pswarpVersion.c            
 

branches/eam_branch_20080719/pswarp/src/pswarp.c

@@ -16 +16 @@
 
     psLibInit(NULL);
+
+    // create the thread pool with 4 threads, supplying our thread launcher function
+    psThreadPoolInit (4, &pswarpThreadLauncher);
+    
+    srand48(0);
+
+    for (int i = 0; i < 10; i++) {
+        // allocate a job which takes two arguments
+        // XXX probably don't need to pre-specify the number of args
+        psThreadJob *job = psThreadJobAlloc ("THREAD_TEST", 2);
+
+        // construct the arguments for this job
+        char *arg1 = NULL;
+        char *arg2 = NULL;
+        psStringAppend (&arg1, "arg1.%d", i);
+        psStringAppend (&arg2, "arg2.%d", i);
+        psArrayAdd (job->args, 1, arg1);
+        psArrayAdd (job->args, 1, arg2);
+
+        psThreadJobAddToQueue (job);
+    }
+    if (!psThreadPoolWait ()) {
+        fprintf (stderr, "error in a threaded job\n");
+        exit (1);
+    }
+    fprintf (stderr, "success for threaded jobs\n");
+    exit (0);
 
     // model inits are needed in pmSourceIO

branches/eam_branch_20080719/pswarp/src/pswarp.h

@@ -68 +68 @@
     );
 
+// thread launcher for this program
+void *pswarpThreadLauncher (void *data);