Don't create to many threads per JSON request/notification

Author: d-biehl

robotcode/language_server/common/lsp_types.py

@@ -1998,6 +1998,7 @@ class SemanticTokenTypes(Enum):
     NUMBER = "number"
     REGEXP = "regexp"
     OPERATOR = "operator"
+    DECORATOR = "decorator"
 
     def __repr__(self) -> str:  # pragma: no cover
         return super().__str__()

robotcode/language_server/robotframework/parts/codelens.py

@@ -3,7 +3,7 @@
 import ast
 from typing import TYPE_CHECKING, Any, List, Optional, Set, Tuple, cast
 
-from ....utils.async_tools import create_sub_task, threaded
+from ....utils.async_tools import create_sub_task
 from ....utils.logging import LoggingDescriptor
 from ...common.decorators import language_id
 from ...common.lsp_types import CodeLens, Command
@@ -38,7 +38,6 @@ async def codelens_refresh(self, sender: Any) -> None:  # NOSONAR
         await self.parent.code_lens.refresh()
 
     @language_id("robotframework")
-    @threaded()
     async def collect(self, sender: Any, document: TextDocument) -> Optional[List[CodeLens]]:
 
         from ..utils.async_ast import AsyncVisitor
@@ -91,7 +90,6 @@ async def visit_KeywordName(self, node: ast.AST) -> None:  # noqa: N802
         return await Visitor.find_from(await self.parent.documents_cache.get_model(document), self)
 
     @language_id("robotframework")
-    @threaded()
     async def resolve(self, sender: Any, code_lens: CodeLens) -> Optional[CodeLens]:
         if code_lens.data is None:
             return code_lens

robotcode/language_server/robotframework/parts/completion.py

@@ -23,7 +23,6 @@
 )
 
 from ....utils.async_itertools import async_chain, async_chain_iterator, async_next
-from ....utils.async_tools import threaded
 from ....utils.logging import LoggingDescriptor
 from ...common.decorators import language_id, trigger_characters
 from ...common.lsp_types import (
@@ -103,7 +102,6 @@ async def get_section_style(self, document: TextDocument) -> str:
     )
     # @all_commit_characters(['\n'])
     @language_id("robotframework")
-    @threaded()
     @_logger.call
     async def collect(
         self, sender: Any, document: TextDocument, position: Position, context: Optional[CompletionContext]
@@ -123,10 +121,8 @@ async def collect(
         )
 
     @language_id("robotframework")
-    @threaded()
     @_logger.call
     async def resolve(self, sender: Any, completion_item: CompletionItem) -> CompletionItem:
-
         if completion_item.data is not None:
             document_uri = completion_item.data.get("document_uri", None)
             if document_uri is not None:

robotcode/language_server/robotframework/parts/document_highlight.py

@@ -2,7 +2,6 @@
 
 from typing import TYPE_CHECKING, Any, List, Optional
 
-from ....utils.async_tools import threaded
 from ....utils.logging import LoggingDescriptor
 from ...common.decorators import language_id
 from ...common.lsp_types import DocumentHighlight, DocumentHighlightKind, Position
@@ -24,7 +23,6 @@ def __init__(self, parent: RobotLanguageServerProtocol) -> None:
         parent.document_highlight.collect.add(self.collect)
 
     @language_id("robotframework")
-    @threaded()
     @_logger.call
     async def collect(
         self,

robotcode/language_server/robotframework/parts/document_symbols.py

@@ -4,7 +4,6 @@
 import itertools
 from typing import TYPE_CHECKING, Any, List, Optional, Union, cast
 
-from ....utils.async_tools import threaded
 from ....utils.logging import LoggingDescriptor
 from ...common.decorators import language_id
 from ...common.lsp_types import DocumentSymbol, SymbolInformation, SymbolKind
@@ -31,7 +30,6 @@ def __init__(self, parent: RobotLanguageServerProtocol) -> None:
         parent.document_symbols.collect.add(self.collect)
 
     @language_id("robotframework")
-    @threaded()
     @_logger.call
     async def collect(
         self, sender: Any, document: TextDocument

robotcode/language_server/robotframework/parts/folding_range.py

@@ -3,7 +3,6 @@
 import ast
 from typing import TYPE_CHECKING, Any, List, Optional, cast
 
-from ....utils.async_tools import threaded
 from ....utils.logging import LoggingDescriptor
 from ...common.decorators import language_id
 from ...common.lsp_types import FoldingRange
@@ -24,7 +23,6 @@ def __init__(self, parent: RobotLanguageServerProtocol) -> None:
         parent.folding_ranges.collect.add(self.collect)
 
     @language_id("robotframework")
-    @threaded()
     @_logger.call
     async def collect(self, sender: Any, document: TextDocument) -> Optional[List[FoldingRange]]:
 

robotcode/language_server/robotframework/parts/formatting.py

@@ -6,7 +6,6 @@
 import re
 from typing import TYPE_CHECKING, Any, List, Optional, cast
 
-from ....utils.async_tools import threaded
 from ....utils.logging import LoggingDescriptor
 from ...common.decorators import language_id
 from ...common.lsp_types import (
@@ -61,7 +60,6 @@ async def get_config(self, document: TextDocument) -> Optional[RoboTidyConfig]:
         return await self.parent.workspace.get_configuration(RoboTidyConfig, folder.uri)
 
     @language_id("robotframework")
-    @threaded()
     @_logger.call
     async def format(
         self, sender: Any, document: TextDocument, options: FormattingOptions, **further_options: Any

robotcode/language_server/robotframework/parts/goto.py

@@ -16,7 +16,6 @@
 )
 
 from ....utils.async_itertools import async_next
-from ....utils.async_tools import threaded
 from ....utils.logging import LoggingDescriptor
 from ....utils.uri import Uri
 from ...common.decorators import language_id
@@ -72,15 +71,13 @@ def _find_method(self, cls: Type[Any]) -> Optional[_CollectMethod]:
         return None
 
     @language_id("robotframework")
-    @threaded()
     @_logger.call
     async def collect_definition(
         self, sender: Any, document: TextDocument, position: Position
     ) -> Union[Location, List[Location], List[LocationLink], None]:
         return await self.collect(document, position, CollectType.DEFINITION)
 
     @language_id("robotframework")
-    @threaded()
     @_logger.call
     async def collect_implementation(
         self, sender: Any, document: TextDocument, position: Position

robotcode/language_server/robotframework/parts/hover.py

@@ -15,7 +15,6 @@
 )
 
 from ....utils.async_itertools import async_next
-from ....utils.async_tools import threaded
 from ....utils.logging import LoggingDescriptor
 from ...common.decorators import language_id
 from ...common.lsp_types import Hover, MarkupContent, MarkupKind, Position
@@ -62,7 +61,6 @@ def _find_method(self, cls: Type[Any]) -> Optional[_HoverMethod]:
 
         return None
 
-    @threaded()
     @language_id("robotframework")
     @_logger.call
     async def collect(self, sender: Any, document: TextDocument, position: Position) -> Optional[Hover]:

robotcode/language_server/robotframework/parts/inline_value.py

@@ -4,7 +4,6 @@
 from typing import TYPE_CHECKING, Any, Generator, List, Optional, Tuple
 
 from ....utils.async_itertools import async_dropwhile, async_takewhile
-from ....utils.async_tools import threaded
 from ....utils.logging import LoggingDescriptor
 from ...common.decorators import language_id
 from ...common.lsp_types import (
@@ -39,7 +38,6 @@ def __init__(self, parent: RobotLanguageServerProtocol) -> None:
         parent.inline_value.collect.add(self.collect)
 
     @language_id("robotframework")
-    @threaded()
     @_logger.call
     async def collect(
         self, sender: Any, document: TextDocument, range: Range, context: InlineValueContext