diff --git a/src/pipewire/data-loop.c b/src/pipewire/data-loop.c
index 3cee8a2..e2ea8f5 100644
--- a/src/pipewire/data-loop.c
+++ b/src/pipewire/data-loop.c
@@ -276,8 +276,8 @@ int pw_data_loop_stop(struct pw_data_loop *loop)
 	if (loop->running) {
 		struct spa_thread_utils *utils;
 		if (loop->cancel) {
-			pw_log_debug("%p cancel", loop);
-			pthread_cancel(loop->thread);
+			pw_log_debug("%p cancel (used pthread_kill as cancel not available on android)", loop);
+			pthread_kill(loop->thread, SIGUSR2);
 		} else {
 			pw_log_debug("%p signal", loop);
 			pw_loop_invoke(loop->loop, do_stop, 1, NULL, 0, false, loop);
diff --git a/src/pipewire/thread.c b/src/pipewire/thread.c
index cf656fb..ba5193f 100644
--- a/src/pipewire/thread.c
+++ b/src/pipewire/thread.c
@@ -79,9 +79,44 @@ static int thread_setaffinity(pthread_t thread, const char *affinity)
 {
 	cpu_set_t set;
 	parse_affinity(affinity, &set);
+#ifdef __ANDROID__
+	return -sched_setaffinity(pthread_gettid_np(thread), sizeof(set), &set);
+#else
 	return -pthread_setaffinity_np(thread, sizeof(set), &set);
+#endif
+}
+
+#ifdef __ANDROID__
+typedef struct wrapped_thread_start {
+	void *(*start)(void *);
+	void *arg;
+} wrapped_thread_start_t;
+
+static void thread_signal_handler(int signum)
+{
+	pthread_exit(0);
 }
 
+static void *pthread_create_wrapper(void *wrapped_arg)
+{
+	wrapped_thread_start_t *wrapped_start = (wrapped_thread_start_t *)wrapped_arg;
+
+	struct sigaction actions;
+	memset(&actions, 0, sizeof(actions));
+	sigemptyset(&actions.sa_mask);
+	actions.sa_flags = 0;
+	actions.sa_handler = thread_signal_handler;
+	sigaction(SIGUSR2, &actions, NULL);
+
+	void *(*start)(void *) = wrapped_start->start;
+	void *arg = wrapped_start->arg;
+
+	free(wrapped_start);
+
+	return (*start)(arg);
+}
+#endif
+
 static struct spa_thread *impl_create(void *object,
 			const struct spa_dict *props,
 			void *(*start)(void*), void *arg)
@@ -93,7 +128,16 @@ static struct spa_thread *impl_create(void *object,
 
 	attr = pw_thread_fill_attr(props, &attributes);
 
+#ifndef __ANDROID__
 	err = pthread_create(&pt, attr, start, arg);
+#else
+	wrapped_thread_start_t *wrapped_start = malloc(sizeof(wrapped_thread_start_t));
+	if (wrapped_start == NULL)
+		return NULL;
+	wrapped_start->start = start;
+	wrapped_start->arg = arg;
+	err = pthread_create(&pt, attr, pthread_create_wrapper, wrapped_start);
+#endif
 
 	if (attr)
 		pthread_attr_destroy(attr);