/art/test/114-ParallelGC/src/ |
Main.java | 33 // Use a cyclic system of synchronous queues to pass a boolean token around. 48 List<SynchronousQueue<Boolean>> queues = new ArrayList<SynchronousQueue<Boolean>>( local 51 queues.add(new SynchronousQueue<Boolean>()); 55 threads[i] = new Thread(new Main(i, queues.get(i), queues.get((i + 1) % threads.length), 63 checkTimeout(queues.get(0).offer(Boolean.TRUE, TIMEOUT_VALUE, TimeUnit.MINUTES));
|
/prebuilts/python/darwin-x86/2.7.5/lib/python2.7/multiprocessing/ |
__init__.py | 217 from multiprocessing.queues import Queue 224 from multiprocessing.queues import JoinableQueue
|
pool.py | 232 from .queues import SimpleQueue
|
/prebuilts/python/linux-x86/2.7.5/lib/python2.7/multiprocessing/ |
__init__.py | 217 from multiprocessing.queues import Queue 224 from multiprocessing.queues import JoinableQueue
|
pool.py | 232 from .queues import SimpleQueue
|
/external/chromium_org/third_party/WebKit/PerformanceTests/Dromaeo/resources/dromaeo/web/ |
webrunner.js | 25 if ( !queues[testName] ) return; 31 queues[testID].push(function(){ 39 if ( !queues[testName] ) return; 40 queues[testID].push(function(){ 48 if ( !queues[testName] ) return; 50 queues[testID].push(function(){ 60 if ( !queues[testName] ) return; 81 queues[testID].push(function(){ 211 var queues = {}; 329 queues[name] = [] [all...] |
/hardware/libhardware/modules/sensors/ |
multihal.cpp | 46 // This mutex is shared by all queues 199 std::vector<SensorEventQueue*> queues; member in struct:sensors_poll_context_t 215 this->queues.push_back(queue); 337 queueCount = (int)this->queues.size(); 340 SensorEventQueue* queue = this->queues.at(this->nextReadIndex); 358 // The queues have been scanned and none contain data, so wait.
|
/external/smack/src/org/jivesoftware/smackx/workgroup/agent/ |
AgentSession.java | 49 * the status, tracking the status of queues to which the agent belongs within the workgroup, and
66 private Map<String, WorkgroupQueue> queues;
field in class:AgentSession 102 this.queues = new HashMap<String, WorkgroupQueue>();
552 return queues.get(queueName);
556 return Collections.unmodifiableMap((new HashMap<String, WorkgroupQueue>(queues))).values().iterator();
702 WorkgroupQueue queue = queues.get(queueName);
706 queues.put(queueName, queue);
[all...] |
/bionic/libc/kernel/uapi/sound/ |
asequencer.h | 235 int queues; member in struct:snd_seq_system_info
|
/external/kernel-headers/original/uapi/sound/ |
asequencer.h | 170 #define SNDRV_SEQ_ADDRESS_BROADCAST 255 /* send event to all queues/clients/ports/channels */ 311 int queues; /* maximum queues count */ member in struct:snd_seq_system_info 316 int cur_queues; /* current queues */ 377 #define SNDRV_SEQ_REMOVE_INPUT (1<<0) /* Flush input queues */ 378 #define SNDRV_SEQ_REMOVE_OUTPUT (1<<1) /* Flush output queues */ 479 unsigned locked:1; /* timing queue locked for other queues */
|
/prebuilts/gcc/linux-x86/host/x86_64-linux-glibc2.11-4.6/sysroot/usr/include/sound/ |
asequencer.h | 170 #define SNDRV_SEQ_ADDRESS_BROADCAST 255 /* send event to all queues/clients/ports/channels */ 311 int queues; /* maximum queues count */ member in struct:snd_seq_system_info 316 int cur_queues; /* current queues */ 377 #define SNDRV_SEQ_REMOVE_INPUT (1<<0) /* Flush input queues */ 378 #define SNDRV_SEQ_REMOVE_OUTPUT (1<<1) /* Flush output queues */ 479 unsigned locked:1; /* timing queue locked for other queues */
|
/prebuilts/gcc/linux-x86/host/x86_64-linux-glibc2.11-4.8/sysroot/usr/include/sound/ |
asequencer.h | 170 #define SNDRV_SEQ_ADDRESS_BROADCAST 255 /* send event to all queues/clients/ports/channels */ 311 int queues; /* maximum queues count */ member in struct:snd_seq_system_info 316 int cur_queues; /* current queues */ 377 #define SNDRV_SEQ_REMOVE_INPUT (1<<0) /* Flush input queues */ 378 #define SNDRV_SEQ_REMOVE_OUTPUT (1<<1) /* Flush output queues */ 479 unsigned locked:1; /* timing queue locked for other queues */
|
/external/chromium_org/ui/file_manager/image_loader/ |
worker.js | 89 // Remove from the internal queues with pending tasks.
|
/external/chromium_org/chrome/browser/resources/cryptotoken/ |
hidgnubbydevice.js | 239 // SYNC|INIT gets to go to the device to flush OS tx/rx queues. 343 * Updates the lock, and queues the frame for sending. Also begins sending if
|
usbgnubbydevice.js | 308 // SYNC|INIT get to go to the device to flush OS tx/rx queues.
|
/external/chromium_org/chrome/common/extensions/docs/examples/extensions/irc/servlet/jstemplate/ |
jstemplate.js | 339 * A stack of queues of pre-order calls. 340 * The inner arrays (constituent queues) are structured as 345 * The outer array is a stack of such queues. 353 * be to maintain the queues in reverse order (popping off of the [all...] |
/external/chromium_org/third_party/jstemplate/ |
jstemplate.js | 321 * A stack of queues of pre-order calls. 322 * The inner arrays (constituent queues) are structured as 327 * The outer array is a stack of such queues. 335 * be to maintain the queues in reverse order (popping off of the
|
/external/blktrace/btt/doc/ |
btt.tex | 264 During normal operation, requests queues are \emph{plugged} and during 275 There are two major reasons why request queues are unplugged, and both 531 being traced, that request queues Q and C traces are presented. 548 is seeing relatively continuous incoming queues. Conversely, when it is [all...] |
/external/iproute2/doc/ |
ip-tunnels.tex | 443 just because they have no queues. Instead, it is better to create classes
|
/external/qemu/qapi-auto-generated/ |
qapi-types.h | 2669 uint32_t queues; member in struct:NetdevTapOptions [all...] |
qapi-visit.c | [all...] |
/prebuilts/tools/common/netbeans-visual/ |
org-openide-util.jar | |