/macosx-10.9.5/ruby-104/ruby/lib/ |
H A D | thwait.rb | 11 # This class watches for termination of multiple threads. Basic functionality 12 # (wait until specified threads have terminated) can be accessed through the 31 def_exception("ErrNoWaitingThread", "No threads for waiting.") 32 def_exception("ErrNoFinishedThread", "No finished threads.") 35 # Waits until all specified threads have terminated. If a block is provided, 38 def ThreadsWait.all_waits(*threads) # :yield: thread 39 tw = ThreadsWait.new(*threads) 50 # Creates a ThreadsWait object, specifying the threads to wait on. 53 def initialize(*threads) 54 @threads [all...] |
H A D | tracer.rb | 109 @threads = Hash.new 111 @threads[Thread.main.object_id] = 0 113 @threads[Thread.current.object_id] = 0 178 if no = @threads[Thread.current.object_id] 181 @threads[Thread.current.object_id] = @threads.size
|
/macosx-10.9.5/tcl-102/tcl_ext/thread/thread/win/ |
H A D | CONFIG | 20 sh ../configure --enable-threads --with-tcl=e:/tcl/win
|
/macosx-10.9.5/ruby-104/ruby/lib/rake/ |
H A D | thread_pool.rb | 14 @threads = Set.new 43 # Waits until the queue of futures is empty and all threads have exited. 48 @join_cond.wait unless @threads.empty? 53 $stderr.print "Queue contains #{@queue.size} items. Thread pool contains #{@threads.count} threads\n" 56 @threads.each do |t| 112 next unless @threads.count < @max_active_threads 116 while @threads.count <= @max_active_threads 121 @threads.delete Thread.current 122 stat :ended, :thread_count => @threads [all...] |
H A D | thread_history_display.rb | 8 private_reader :stats, :items, :threads 13 @threads = { :_seq_ => "A" } 20 rename(stat, :thread, threads) 22 rename(stat[:data], :new_thread, threads) 23 rename(stat[:data], :deleted_thread, threads)
|
/macosx-10.9.5/libauto-185.5/tests/ |
H A D | mallocfree.m | 44 pthread_t threads[nthreads]; 46 pthread_create(&threads[i], NULL, allocFreeALot, NULL); 49 pthread_join(threads[i], NULL);
|
/macosx-10.9.5/ruby-104/ruby/lib/minitest/ |
H A D | parallel_each.rb | 26 threads = N.times.map { 34 threads.map(&:join)
|
/macosx-10.9.5/CPANInternal-140/Test-Simple/t/ |
H A D | is_deeply_with_threads.t | 3 # Test to see if is_deeply() plays well with threads. 20 eval { require threads; 'threads'->import; 1; }) 22 print "1..0 # Skip no working threads\n"; 27 print "1..0 # Skip many perls have broken threads. Enable with AUTHOR_TESTING.\n"; 55 my $t = threads->new(\&do_one_thread, $i); 62 cmp_ok( $rc, '==', 42, "threads exit status is $rc" );
|
H A D | threads.t | 13 eval { require threads; 'threads'->import; 1; }) 15 print "1..0 # Skip: no working threads\n"; 28 'threads'->create(sub {
|
H A D | diag.t | 14 # Turn on threads here, if available, since this test tends to find 19 require threads; 20 'threads'->import;
|
H A D | overload_threads.t | 15 # There was a bug with overloaded objects and threads. 17 eval { require threads; 'threads'->import; 1; };
|
/macosx-10.9.5/xnu-2422.115.4/tools/tests/execperf/ |
H A D | run.c | 22 pthread_t *threads; local 33 threads = (pthread_t *)calloc(threadcount, sizeof(pthread_t)); 35 ret = pthread_create(&threads[i], NULL, work, (void *)(intptr_t)count); 42 ret = pthread_join(threads[i], NULL);
|
/macosx-10.9.5/xnu-2422.115.4/tools/tests/unit_tests/ |
H A D | test_waitqlocktry_12053360.c | 3 * Test Description: This is a load test for wait queues in the kernel. It is designed to excercise the locking of threads and 33 pthread_t *threads; local 39 printf("Currently defaulting to 100us and 100 threads\n"); 54 printf("Num threads must be > 0.\n"); 59 threads = (pthread_t*)malloc(nthreads * sizeof(pthread_t)); 60 if (threads == NULL) { 65 printf("Creating %u threads with a max sleep time of %uusec.\n", nthreads, test_usleep_max); 68 result = pthread_create(&threads[i], NULL, test_thread, NULL);
|
/macosx-10.9.5/WebCore-7537.78.1/storage/ |
H A D | StorageThread.cpp | 39 DEFINE_STATIC_LOCAL(HashSet<StorageThread*>, threads, ()); 40 return threads; 114 HashSet<StorageThread*>& threads = activeStorageThreads(); local 116 for (HashSet<StorageThread*>::iterator it = threads.begin(), end = threads.end(); it != end; ++it)
|
/macosx-10.9.5/CPANInternal-140/Variable-Magic/t/ |
H A D | 41-clone.t | 17 skipall 'This perl wasn\'t built to support threads' 19 skipall "threads $t_v required to test thread safety" 20 unless eval "use threads $t_v; 1"; 21 skipall "threads::shared $ts_v required to test thread safety" 22 unless eval "use threads::shared $ts_v; 1"; 25 use Test::More; # after threads 32 my $v = $threads::VERSION; 33 diag "Using threads $v" if defined $v; 34 $v = $threads::shared::VERSION; 35 diag "Using threads [all...] |
H A D | 40-threads.t | 17 skipall 'This perl wasn\'t built to support threads' 19 skipall "threads $t_v required to test thread safety" 20 unless eval "use threads $t_v; 1"; 21 skipall "threads::shared $ts_v required to test thread safety" 22 unless eval "use threads::shared $ts_v; 1"; 25 use Test::More; # after threads 32 my $v = $threads::VERSION; 33 diag "Using threads $v" if defined $v; 34 $v = $threads::shared::VERSION; 35 diag "Using threads [all...] |
/macosx-10.9.5/ruby-104/ruby/sample/ |
H A D | dualstack-httpd.rb | 12 threads = [] 25 threads[i] = Thread.start do # Thread.start cannot be used here! 53 for t in threads
|
/macosx-10.9.5/libclosure-63/objectTests/ |
H A D | tlctester.mm | 87 if (verbose) printf("running %d threads for %d seconds\n", nthreads, sleeptime); 88 pthread_t threads[nthreads]; 96 pthread_create(&threads[i], NULL, callBlock, (void *)Block_copy(setter)); 106 pthread_create(&threads[i], NULL, callBlock, (void *)Block_copy(getter)); 110 pthread_join(threads[i], NULL);
|
/macosx-10.9.5/ruby-104/ruby/test/rake/ |
H A D | test_rake_thread_pool.rb | 24 threads = 2.times.collect{ pool.future{ sleep 0.1; Thread.current } }.each{|f|f.value} 26 refute_equal threads[0], threads[1] 27 refute_equal Thread.current, threads[0] 28 refute_equal Thread.current, threads[1] 33 threads = Set.new 38 t_mutex.synchronize{ threads << Thread.current } 42 assert_equal 2, threads.count
|
/macosx-10.9.5/ruby-104/ruby/test/thread/ |
H A D | test_cv.rb | 57 threads = Array.new 63 threads[i] = Thread.new do 78 threads[i].join 85 assert_in_out_err([], <<-INPUT, ["fatal", "No live threads left. Deadlock?"], []) 108 threads = Array.new 116 threads[i] = Thread.new do 128 threads.each(&:kill) 129 threads.each(&:join)
|
/macosx-10.9.5/bind9-45.100/bind9/ |
H A D | config.threads.in | 44 # startup when built with threads. 62 AC_ARG_ENABLE(threads, 63 [ --enable-threads enable multithreading]) 75 AC_MSG_ERROR([--enable-threads takes yes or no]) 94 # the ability to choose threads library at final
|
/macosx-10.9.5/system_cmds-597.90.1/mean.tproj/ |
H A D | mean.c | 40 thread_act_array_t threads; local 84 err = task_threads(task, &threads, &count); 96 err = thread_policy_set(threads[i], 106 printf("Process %d's threads set to %s priority.\n", pid,
|
/macosx-10.9.5/system_cmds-597.90.1/system_cmds-597.1.1/mean.tproj/ |
H A D | mean.c | 40 thread_act_array_t threads; local 84 err = task_threads(task, &threads, &count); 96 err = thread_policy_set(threads[i], 106 printf("Process %d's threads set to %s priority.\n", pid,
|
/macosx-10.9.5/xnu-2422.115.4/libsyscall/wrappers/libproc/ |
H A D | proc_listpidspath.c | 39 // threads 40 uint64_t *threads; member in struct:__anon15196 75 info->threads = NULL; 109 if (info->threads != NULL) { 110 free(info->threads); 382 // get list of threads 392 if (info->threads == NULL) { 393 info->threads = malloc(info->thr_size); 395 info->threads = reallocf(info->threads, inf [all...] |
/macosx-10.9.5/CPANInternal-140/Net-Daemon-0.48/ |
H A D | regexp-threads | 21 eval {require threads::shared}; 26 eval { threads::shared::share($numChilds) };
|