Home
last modified time | relevance | path

Searched refs:thread (Results 1 – 25 of 68) sorted by relevance

123

/packages/apps/Gallery2/src/com/android/gallery3d/util/
DProfile.java42 Thread thread; field in Profile.WatchEntry
77 public synchronized void addWatchEntry(Thread thread, int cycleTime) { in addWatchEntry() argument
79 e.thread = thread; in addWatchEntry()
87 public synchronized void removeWatchEntry(Thread thread) { in removeWatchEntry() argument
89 if (mList.get(i).thread == thread) { in removeWatchEntry()
112 Thread thread = entry.thread; in processList() local
126 Thread thread = entry.thread; in sampleStack() local
127 StackTraceElement[] stack = thread.getStackTrace(); in sampleStack()
139 private WatchEntry findEntry(Thread thread) { in findEntry() argument
142 if (entry.thread == thread) return entry; in findEntry()
/packages/apps/Camera2/src/com/android/camera/async/
DHandlerFactory.java32 final HandlerThread thread = new HandlerThread(threadName); in create() local
33 thread.start(); in create()
38 thread.quitSafely(); in create()
42 return new Handler(thread.getLooper()); in create()
52 final HandlerThread thread = new HandlerThread(threadName); in create() local
53 thread.start(); in create()
54 thread.setPriority(javaThreadPriority); in create()
59 thread.quitSafely(); in create()
63 return new Handler(thread.getLooper()); in create()
/packages/apps/Dialer/java/com/android/dialer/common/concurrent/
DDialerExecutorModule.java63 Thread thread = new Thread(runnable, "DialerExecutors-LowPriority"); in provideNonUiThreadPool()
65 thread.setPriority(4); in provideNonUiThreadPool()
66 return thread; in provideNonUiThreadPool()
80 Thread thread = new Thread(runnable, "DialerExecutors-LowPriority-Serial");
82 thread.setPriority(4);
83 return thread;
103 Thread thread = new Thread(runnable, "DialerExecutors-HighPriority-Serial");
105 thread.setPriority(5);
106 return thread;
/packages/modules/DnsResolver/
DREADME-DoT.md15 network. `DnsTlsDispatcher` also blocks each query thread, waiting on a
20 `DnsTlsSocket`, which happen on a different thread.
37 For clarity, each of the five classes in this design is thread-safe and holds one lock.
38 Classes that spawn a helper thread call `thread::join()` in their destructor to ensure
41 All the classes here make full use of Clang thread annotations (and also null-pointer
45 This code creates O(1) threads per socket, and does not create a new thread for each
46 query or response. However, DnsProxyListener does create a thread for each query.
50 `DnsTlsSocket` can receive queries on any thread, and send them over a
53 from its thread, and the loop thread (which owns the SSL socket)
55 instead, any queueing happens by blocking the query thread until the
[all …]
Dresolv_cache_unit_test.cpp459 std::vector<std::thread> threads(5); in TEST_F()
460 for (std::thread& thread : threads) { in TEST_F()
461 thread = std::thread([&]() { in TEST_F()
489 for (std::thread& thread : threads) { in TEST_F()
490 thread.join(); in TEST_F()
502 std::vector<std::thread> threads(5); in TEST_F()
503 for (std::thread& thread : threads) { in TEST_F()
504 thread = std::thread([&]() { in TEST_F()
519 for (std::thread& thread : threads) { in TEST_F()
520 thread.join(); in TEST_F()
[all …]
DDnsQueryLogTest.cpp89 std::vector<std::thread> threads(threadNum); in TEST_F()
92 for (auto& thread : threads) { in TEST_F() local
93 thread = std::thread([&]() { in TEST_F()
100 for (auto& thread : threads) { in TEST_F() local
101 thread.join(); in TEST_F()
Dresolv_tls_unit_test.cpp134 std::thread(&IDnsTlsSocketObserver::onResponse, mObserver, make_echo(id, query)).detach(); in query()
169 std::thread(&IDnsTlsSocketObserver::onResponse, mObserver, response).detach(); in query()
235 std::thread(&FakeSocketDelay::sendResponses, this).detach(); in query()
449 std::thread mCloser;
477 for (auto& thread : mThreads) { in ~FakeSocketLimited() local
479 thread.join(); in ~FakeSocketLimited()
505 mCloser = std::make_unique<std::thread>(&FakeSocketLimited::sendClose, this); in query()
516 for (auto& thread : mThreads) { in sendClose() local
518 thread.join(); in sendClose()
528 std::vector<std::thread> mThreads GUARDED_BY(mLock);
[all …]
/packages/apps/Messaging/src/com/android/messaging/mmslib/util/
DPduCache.java104 HashSet<Uri> thread = mThreads.get(threadId); in put() local
105 if (thread == null) { in put()
106 thread = new HashSet<Uri>(); in put()
107 mThreads.put(threadId, thread); in put()
114 thread.add(finalKey); in put()
233 HashSet<Uri> thread = mThreads.get(entry.getThreadId()); in removeFromThreads() local
234 if (thread != null) { in removeFromThreads()
235 thread.remove(key); in removeFromThreads()
244 HashSet<Uri> thread = mThreads.remove(threadId); in purgeByThreadId() local
245 if (thread != null) { in purgeByThreadId()
[all …]
/packages/providers/DownloadProvider/src/com/android/providers/downloads/
DDownloadJobService.java67 final DownloadThread thread; in onStartJob() local
73 thread = new DownloadThread(this, params, info); in onStartJob()
74 mActiveThreads.put(id, thread); in onStartJob()
76 thread.start(); in onStartJob()
86 final DownloadThread thread; in onStopJob() local
88 thread = mActiveThreads.removeReturnOld(id); in onStopJob()
90 if (thread != null) { in onStopJob()
93 thread.requestShutdown(); in onStopJob()
/packages/modules/DnsResolver/tests/
Dresolv_stress_test.cpp54 std::vector<std::thread> threads(num_threads); in RunGetAddrInfoStressTest()
55 for (std::thread& thread : threads) { in RunGetAddrInfoStressTest()
56 thread = std::thread([&mappings, num_queries]() { in RunGetAddrInfoStressTest()
77 for (std::thread& thread : threads) { in RunGetAddrInfoStressTest()
78 thread.join(); in RunGetAddrInfoStressTest()
/packages/apps/TV/common/src/com/android/tv/common/concurrent/
DNamedThreadFactory.java37 final Thread thread = mDefaultThreadFactory.newThread(runnable); in newThread() local
38 thread.setName(mPrefix + mCount.getAndIncrement()); in newThread()
39 return thread; in newThread()
42 public boolean namedWithPrefix(Thread thread) { in namedWithPrefix() argument
43 return thread.getName().startsWith(mPrefix); in namedWithPrefix()
/packages/apps/Dialer/java/com/android/dialer/simulator/impl/
DSimulatorRemoteVideo.java37 @NonNull private final RenderThread thread; field in SimulatorRemoteVideo
41 thread = new RenderThread(new Renderer(surface)); in SimulatorRemoteVideo()
47 thread.start(); in startVideo()
53 thread.quitSafely(); in stopVideo()
58 return thread.getRenderer(); in getRenderer()
/packages/apps/Gallery/src/com/android/camera/
DBitmapManager.java183 Thread thread = Thread.currentThread(); in decodeFileDescriptor() local
184 if (!canThreadDecoding(thread)) { in decodeFileDescriptor()
185 Log.d(TAG, "Thread " + thread + " is not allowed to decode."); in decodeFileDescriptor()
189 setDecodingOptions(thread, options); in decodeFileDescriptor()
192 removeDecodingOptions(thread); in decodeFileDescriptor()
/packages/inputmethods/LatinIME/java/src/com/android/inputmethod/latin/utils/
DExecutorUtils.java55 Thread thread = new Thread(runnable, TAG); in newThread() local
56 thread.setUncaughtExceptionHandler(new UncaughtExceptionHandler() { in newThread()
58 public void uncaughtException(Thread thread, Throwable ex) { in newThread()
62 return thread; in newThread()
/packages/apps/Messaging/src/com/android/messaging/
DBugleApplication.java184 public void uncaughtException(final Thread thread, final Throwable ex) { in uncaughtException() argument
185 final boolean background = getMainLooper().getThread() != thread; in uncaughtException()
187 LogUtil.e(TAG, "Uncaught exception in background thread " + thread, ex); in uncaughtException()
194 sSystemUncaughtExceptionHandler.uncaughtException(thread, ex); in uncaughtException()
198 sSystemUncaughtExceptionHandler.uncaughtException(thread, ex); in uncaughtException()
/packages/apps/ManagedProvisioning/src/com/android/managedprovisioning/ota/
DPreBootListener.java34 Thread thread = new Thread(() -> { in onReceive() local
38 thread.setPriority(Thread.MAX_PRIORITY); in onReceive()
39 thread.start(); in onReceive()
/packages/apps/ManagedProvisioning/src/com/android/managedprovisioning/manageduser/
DManagedUserCreationListener.java39 Thread thread = new Thread(() -> { in onReceive() local
43 thread.setPriority(Thread.MAX_PRIORITY); in onReceive()
44 thread.start(); in onReceive()
/packages/apps/Launcher3/src/com/android/launcher3/util/
DExecutors.java68 HandlerThread thread = new HandlerThread(name, priority); in createAndStartNewLooper() local
69 thread.start(); in createAndStartNewLooper()
70 return thread.getLooper(); in createAndStartNewLooper()
/packages/services/Car/tests/carservice_test/src/com/android/car/
DCarUxRestrictionsManagerServiceTest.java389 Thread thread = new Thread(propertyChangeEventRunnable); in testInitService_NoDeadlockWithCarDrivingStateService() local
390 thread.start(); in testInitService_NoDeadlockWithCarDrivingStateService()
408 thread.join(5000); in testInitService_NoDeadlockWithCarDrivingStateService()
478 Thread thread = new Thread(propertyChangeEventRunnable); in testSetUxRChangeBroadcastEnabled_NoDeadlockWithCarDrivingStateService() local
479 thread.start(); in testSetUxRChangeBroadcastEnabled_NoDeadlockWithCarDrivingStateService()
497 thread.join(5000); in testSetUxRChangeBroadcastEnabled_NoDeadlockWithCarDrivingStateService()
/packages/services/Car/tools/emulator/
Dvhal_prop_simulator.py49 thread = Thread(target=generator.generate, args=(self,))
50 thread.daemon = True
51 thread.start()
/packages/modules/NetworkStack/tests/integration/src/android/net/netlink/
DInetDiagSocketIntegrationTest.java215 for (Thread thread : threads) { in testB141603906()
216 thread.start(); in testB141603906()
219 for (Thread thread : threads) { in testB141603906()
220 thread.join(); in testB141603906()
/packages/services/Telecomm/src/com/android/server/telecom/
DDtmfLocalTonePlayer.java235 HandlerThread thread = new HandlerThread("tonegenerator-dtmf"); in getHandler() local
236 thread.start(); in getHandler()
237 mHandler = new ToneHandler(thread.getLooper()); in getHandler()
DAsyncRingtonePlayer.java129 HandlerThread thread = new HandlerThread("ringtone-player"); in getNewHandler() local
130 thread.start(); in getNewHandler()
132 return new Handler(thread.getLooper(), null /*callback*/, true /*async*/) { in getNewHandler()
DContactsAsyncHelper.java249 HandlerThread thread = new HandlerThread("ContactsAsyncWorker"); in ensureAsyncHandlerStarted() local
250 thread.start(); in ensureAsyncHandlerStarted()
251 mThreadHandler = new WorkerHandler(thread.getLooper()); in ensureAsyncHandlerStarted()
/packages/services/Car/tests/CarDeveloperOptions/src/com/android/car/developeroptions/nfc/
DPaymentBackend.java177 public void register(Context context, Looper thread, UserHandle user, in register() argument
180 mHandler = new Handler(thread) { in register()
187 super.register(context, thread, user, externalStorage); in register()

123