1 files changed, 94 insertions, 0 deletions
diff --git a/threadlib/test.c b/threadlib/test.c
new file mode 100644
index 0000000..9857832
--- /dev/null
+++ b/threadlib/test.c
@@ -0,0 +1,94 @@
+/*
+** Copyright 2000 Double Precision, Inc.  See COPYING for
+** distribution information.
+*/
+
+
+#include	"config.h"
+#include	<stdio.h>
+#include	<stdlib.h>
+#include	<math.h>
+#include	<errno.h>
+#include	<time.h>
+#include	"threadlib.h"
+
+static double buf[100];
+static int bufcnt=0;
+static unsigned ndelay=0;
+
+static void workfunc(void *p)
+{
+double *dp= (double *)p;
+time_t	t1, t2;
+
+	*dp=sqrt( *dp );
+
+	time(&t1);
+	while ( time(&t2) < t1 + ndelay)
+		;
+}
+
+static void cleanupfunc(void *p)
+{
+double *dp= (double *)p;
+
+	buf[bufcnt++]= *dp;
+}
+
+static void getwork(void *p, void *q)
+{
+double *dp= (double *)p;
+double *qp= (double *)q;
+
+	*dp= *qp;
+}
+
+static int cmpdbl (const void *a, const void *b)
+{
+const double *pa=(const double *)a;
+const double *pb=(const double *)b;
+
+	return (*pa < *pb ? -1: *pa > *pb ? 1:0);
+}
+
+int main(int argc, char **argv)
+{
+double n;
+struct cthreadinfo *cit;
+int	i, j;
+
+	if (argc < 2)	return (1);
+
+	j=atoi(argv[1]);
+	if (argc > 2)
+		ndelay=atoi(argv[2]);
+
+	if (j <= 0 || j > sizeof(buf)/sizeof(buf[0]))	return (1);
+
+	if ( (cit=cthread_init(2, sizeof(double), workfunc, cleanupfunc)) == 0)
+	{
+		perror("cthread_init");
+		return (1);
+	}
+
+	for (i=0; i<j; i++)
+	{
+		n= i+1;
+
+		if (cthread_go(cit, getwork, &n))
+		{
+			perror("cthread_go");
+			return (1);
+		}
+		printf ("Started %d\n", i+1);
+	}
+	cthread_wait(cit);
+
+	qsort(buf, bufcnt, sizeof(buf[0]), &cmpdbl);
+
+	for (i=0; i<bufcnt; i++)
+	{
+		printf("%6.2f\n", buf[i]);
+	}
+	return (0);
+}