Run remote searches at low priority

Author: parg

core/src/com/biglybt/core/content/RelatedContentSearcher.java

@@ -40,6 +40,7 @@
 import com.biglybt.pif.ddb.*;
 import com.biglybt.pif.utils.search.*;
 import com.biglybt.pifimpl.local.ddb.DDBaseImpl;
+import com.biglybt.pifimpl.local.utils.UtilitiesImpl;
 import com.biglybt.plugin.dht.DHTPluginBasicInterface;
 import com.biglybt.plugin.dht.DHTPluginContact;
 import com.biglybt.plugin.dht.DHTPluginInterface.DHTInterface;
@@ -901,6 +902,29 @@
 		int					min_leechers,
 		int					max_age_secs,
 		boolean				is_local )
+	{
+		if ( is_local ){
+			
+			return( matchContent0( term, min_seeds, min_leechers, max_age_secs, is_local ));
+			
+		}else{
+			
+			return( 
+				UtilitiesImpl.runAtLowPriority(
+				"remsearch",
+				()->{
+					return( matchContent0( term, min_seeds, min_leechers, max_age_secs, is_local ));
+				}));
+		}
+	}
+	
+	List<RelatedContent>
+	matchContent0(
+		final String		term,
+		int					min_seeds,
+		int					min_leechers,
+		int					max_age_secs,
+		boolean				is_local )
 	{
 		if ( !is_local ){
 

core/src/com/biglybt/pifimpl/local/utils/UtilitiesImpl.java

@@ -34,6 +34,7 @@
 import java.net.URL;
 import java.nio.ByteBuffer;
 import java.util.*;
+import java.util.function.Supplier;
 
 import com.biglybt.core.Core;
 import com.biglybt.core.ipchecker.extipchecker.ExternalIPChecker;
@@ -1164,6 +1165,53 @@ public DelayedTask createDelayedTask(Runnable target) {
 		return addDelayedTask(pi.getPluginName(), target);
 	}
 
+	public static <T> T
+	runAtLowPriority(
+		String				name,
+		Supplier<T>			r )
+	{
+		Object [] result = { null };
+		
+		AESemaphore sem = new AESemaphore( name );
+		
+		AEThread2.createAndStartDaemon(
+			name,
+			()->{
+				try{
+					Thread t = Thread.currentThread();
+					
+					int p = t.getPriority();
+					
+					t.setPriority( Thread.MIN_PRIORITY );
+					
+					try{
+					
+						T res = r.get();
+					
+						synchronized( result ){
+							
+							result[0] = res;
+						}
+						
+						
+					}finally{
+												
+						t.setPriority( p );
+					}
+				}finally{
+					
+					sem.release();
+				}
+			});
+		
+		sem.reserve();
+		
+		synchronized( result ){
+			
+			return( (T)result[0]);
+		}
+	}
+	
 	private static List			delayed_tasks = new ArrayList();
 	private static AESemaphore	delayed_tasks_sem	= new AESemaphore( "Utilities:delayedTask" );
 	private static AEThread2	delayed_task_thread;