thr_new.c

// Copyright (c) 2013 Adobe Systems Inc

// Permission is hereby granted, free of charge, to any person obtaining a copy
// of this software and associated documentation files (the "Software"), to deal
// in the Software without restriction, including without limitation the rights
// to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
// copies of the Software, and to permit persons to whom the Software is
// furnished to do so, subject to the following conditions:

// The above copyright notice and this permission notice shall be included in
// all copies or substantial portions of the Software.

// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
// OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
// THE SOFTWARE.

// trivial test for "thr_new"
// uses trace to not require posix
#include <sys/thr.h>

static volatile int done = 0;
static int bar = 0;

extern int tprintf(const char *, ...);

static void foo(void *arg)
{
  long n;
  tprintf("in foo -- bar: %d done: %d", *(int *)arg, done);
  n = __sync_add_and_fetch(&done, 1);
  tprintf("(after atomic incr) done: %d", done);
  thr_exit(&n);
}

#define THREADS 4

int main(int argc, char **argv) 
{ 
  int stackSize = 1024*1024;
  void *stacks[THREADS];
  int i;

  for(i = 0; i < THREADS; i++)
    stacks[i] = malloc(stackSize);
  for(i = 0, bar = 123; i < THREADS; i++, bar++)
  {
    long tid;
    struct thr_param param;

    memset(&param, 0, sizeof(param));
    param.stack_base = (char *)stacks[i] + stackSize;
    param.arg = &bar;
    param.start_func = foo;
    param.child_tid = &tid;
    if(!thr_new(&param, sizeof(param)))
      tprintf("new tid: %d", tid);
  }
  while(done != THREADS);
  tprintf("done");
  return 0;
}