If there is a user-level wq library, maybe ls could use it like this

du with wq is more interesting

If there is a user-level wq library, maybe ls could use it like this
119872d2 · Frans Kaashoek · c3171cdc · 119872d2 · 119872d2
--- a/bin/Makefrag
+++ b/bin/Makefrag
@@ -21,6 +21,7 @@ UPROGS= \
 	scripttest \
 	ftest \
 	perf
+	# pls
 ifeq ($(HAVE_LWIP),y)
 UPROGS += \

--- a/bin/pls.cc
+++ b/bin/pls.cc
@@ -2,6 +2,7 @@
 #include "stat.h"
 #include "user.h"
 #include "fs.h"
+#include "wq.hh"
 const char*
 fmtname(const char *path)
@@ -76,6 +77,8 @@ work(void *arg)
  u64 tid = (u64)arg;
  // grab and push work  (may divide into blocks? and call ls on a block)?
  // maybe implement getdirent sys call that gives you some unread dir entry
+  printf("%d\n", tid);
+  while (wq_trywork()) ;
 }
 int
@@ -84,24 +87,27 @@ main(int argc, char *argv[])
  int i;
  int nthread = 4;
-  for(int i = 0; i < nthread; i++) {
+  wq_init(nthread);   // create a workqueue instance with nthread workers
-    sbrk(8192);
-    void *tstack = sbrk(0);
-    // fprintf(1, "tstack %lx\n", tstack);
-    int tid = forkt(tstack, (void*) thr, (void *)(u64)i);
-    if (0) fprintf(1, "pls[%d]: child %d\n", getpid(), tid);
-  }
-  // push work wq.cc
+  // create some intial work
  if(argc < 2){
-    ls(".");
+    // ls(".");
-    exit();
+    struct work *w = (struct work *) malloc(sizeof(struct work));
+    w->rip = (void*) ls;
+    w->arg0 = (void *) ".";
+    wq_push(w);
+  } else {
+    for(i=1; i<argc; i++) {
+      // ls(argv[i]);
+      struct work *w = (struct work *) malloc(sizeof(struct work));
+      w->rip = (void*) ls;
+      w->arg0 = (void *) argv[i];
+      wq_push(w);
+    }
  }
-  for(i=1; i<argc; i++)
-    ls(argv[i]);
-  for(int i = 0; i < nthread; i++)
+  // start workers; terminate when all workers have no work
-    wait();
+  wq_start();
  exit();
 }