Initial commit

Author: Stephen Mathieson

.gitignore

@@ -0,0 +1,7 @@
+deps/
+example
+test/end
+test/new
+test/push
+test/wait
+*.o

Makefile

@@ -0,0 +1,31 @@
+
+CC ?= gcc
+CFLAGS = -std=c99 -Wall -Wextra -Isrc
+LDFLAGS = -pthread
+SRC = $(wildcard src/*.c)
+SRC += $(wildcard deps/*/*.c)
+OBJS = $(SRC:.c=.o)
+TEST_SOURCES = $(wildcard test/*.c)
+TEST_EXECUTABLES = $(TEST_SOURCES:.c=)
+
+test: $(TEST_EXECUTABLES)
+
+$(TEST_EXECUTABLES): CFLAGS += -Wunused-parameter
+$(TEST_EXECUTABLES): CFLAGS += -Ideps/describe -Ideps
+$(TEST_EXECUTABLES): $(OBJS)
+	@$(CC) $@.c $^ -o $@ $(CFLAGS) $(LDFLAGS)
+	@$@
+
+example: CFLAGS += -Wint-to-void-pointer-cast
+example: example.o $(OBJS)
+	$(CC) $^ -o $@ $(CFLAGS) $(LDFLAGS)
+
+%.o: %.c
+	$(CC) $< -c -o $@ $(CFLAGS)
+
+clean:
+	rm -f $(OBJS)
+	rm -f example example.o
+	rm -f $(TEST_OBJECTS) $(TEST_EXECUTABLES)
+
+.PHONY: test clean

Readme.md

@@ -0,0 +1,13 @@
+
+# batch.c
+
+  A tiny async batch thingy using POSIX threads.  Asynchronously execute callbacks in parallel with built-in concurrency control.
+
+## API
+
+```c
+```
+
+## License
+
+  MIT

example.c

@@ -0,0 +1,53 @@
+
+#include <assert.h>
+#include <stdio.h>
+#include <pthread.h> // pthread_self
+#include <unistd.h> // sleep
+#include "batch.h"
+
+int count = 0;
+
+int
+is_even(int n) {
+  return 0 == n % 2 ? 1 : 0;
+}
+
+void *
+function_even(void *arg) {
+  int n = (int) arg;
+  assert(is_even(n));
+  printf("thread 0x%x: EVEN  <-->  %d\n", (int) pthread_self(), n);
+  count++;
+  sleep(1);
+  return NULL;
+}
+
+void *
+function_odd(void *arg) {
+  int n = (int) arg;
+  assert(0 == is_even(n));
+  printf("thread 0x%x: ODD   <-->  %d\n", (int) pthread_self(), n);
+  count++;
+  sleep(1);
+  return NULL;
+}
+
+int
+main() {
+  void *batch = batch_new(4);
+  assert(batch);
+
+  for (int i = 0; i < 20; ++i) {
+    void *(*function)(void *) = is_even(i)
+      ? function_even
+      : function_odd;
+    batch_push(batch, function, (void *) i);
+  }
+
+  batch_wait(batch);
+  batch_end(batch);
+
+  assert(20 == count);
+
+  return 0;
+}

package.json

@@ -0,0 +1,12 @@
+{
+  "name": "batch",
+  "version": "0.0.0",
+  "repo": "stephenmathieson/batch.c",
+  "description": "A tiny async batch thingy using POSIX threads",
+  "keywords": ["pthread", "async", "concurrency"],
+  "license": "MIT",
+  "src": ["src/batch.h", "src/batch.c"],
+  "development": {
+    "stephenmathieson/describe.h": "*"
+  }
+}