Runable vs Callable

Runable là một interface mà nó dùng cho viêc thực hiện một công việc mất nhiều thời gian phản hồi ngay lập tức

Bạn sẽ không thể nhận kết quả là 1 giá trị khi thực hiện xong Runable

Vậy việc lấy giá trị sau khi thời gian chạy như vậy thì làm thế nào???

Bạn hoàn toàn có thể dùng biến share giữa các luồng để check và lấy giá trị

Với sự phức tạp việc quản lý task khi dùng chung biến share

Java đã phát triển một interface Callable

Callable chạy task ngầm như Runable nhưng nó hỗ trợ trả về dữ liệu sau khi thực hiện xong task
do vậy chúng ta có thể truy cập giá trị dễ dàng

vậy làm cách nào để lấy giá trị đó

Chúng ta phải dùng một Class là Future để thực hiện việc lấy dữ liệu thông qua Future.get()
 là phương thức để lấy dữ liệu, khi phương thức get() được thực hiện nó sẽ block luồng hiện tại và chờ đợi khi có dữ liệu trả về

vậy điều gì nếu hàm get() bị timeout khi dữ liệu không trả về sau 1 thời gian
-- Luồng sẽ bị timeout theo

Vậy Completeable sẽ giải quyết được điều đó

Nó sẽ có tác dụng như Future

Nhưng nó có thêm hàm Completeable.complete("Giá trị trả về trong trường hợp hàm get() không trả về giá trị do timeout"). Do đó hàm này nên để trong một thread khác để check thời gian hoặc một điều kiệu nào đó

Comments

Post a Comment

Popular posts from this blog

Fixing the DeepSpeed Import Error While Fine-Tuning the Qwen Model

While fine-tuning the Qwen model, I encountered an error in the finetune.py script: ImportError : cannot import name 'deepspeed' from 'transformers.deepspeed' After some investigation, I discovered the issue stems from a recent update in the Transformers library. The transformers.deepspeed module has been deprecated and replaced by transformers.integrations . To fix this, you need to update the import statement in your script. The Fix Replace this: from transformers.deepspeed import deepspeed With this: from transformers.integrations import deepspeed This small change resolved the error, allowing the fine-tuning process to proceed smoothly. Additional Resources For more details, refer to the discussion in the official Transformers GitHub repository: Issue #34582 Remember to keep your library versions up-to-date to avoid similar issues in the future! 
Read more

Amazon Linux 2023 - User data configuration for launch templates to connect to the EKS cluster

  Amazon Linux 2023 (AL2023) introduces a new node initialization process nodeadm that uses a YAML configuration schema. If you’re using self-managed node groups or an AMI with a launch template, you’ll now need to provide additional cluster metadata explicitly when creating a new node group MIME-Version: 1.0 Content-Type: multipart/mixed; boundary="//" --// Content-Type: application/node.eks.aws --- apiVersion: node.eks.aws/v1alpha1 kind: NodeConfig spec: cluster: name: my-cluster-name-prd apiServerEndpoint: https://D59F.xyz.ap-northest-2.eks.amazonaws.com certificateAuthority: Y2VydGlmaWNhdGVBdXRob3JpdHk= cidr: 172.10.0.0/16 kubelet: config: clusterDNS: - 172.10.0.10 flags: - --node-labels=app=my-app,environment=production --// Content-Type: text/x-shellscript; charset="us-ascii" #!/bin/bash set -o errexit set -o pipefail set -o nounset # Install additional packages yum install -y htop jq iptables-services --//--
Read more

How to create ISM policy and rotate logs in opensearch

  { "id" : "k8s_ingress-nginx" , "policy" : { "policy_id" : "k8s_ingress-nginx" , "description" : "Move indices into a cold state after 30 days and delete them after a year." , "default_state" : "hot" , "states" : [ { "name" : "hot" , "actions" : [ { "replica_count" : { "number_of_replicas" : 1 } } ] , "transitions" : [ { "state_name" : "cold" , "conditions" : { "min_index_age" : "3d" } ...
Read more