Engelleme soketini gerçekleştiren bir iş parçacığı nasıl bağlanır?

Question

Uzak bir ana bilgisayara bir soket bağlantısı yapmayı deneyen pthread ortaya çıkan bazı kodlarım var. Bağlantı hiç kaybolursa, soketinde connect() numaralı bir engellemeyi kullanarak yeniden bağlanmayı dener. Kod ayrı bir iş parçacığı içinde çalıştığı için, eşzamanlı soket API'sini kullanması gerçekten umrumda değil.

Uygulamamın çıkma zamanı gelene kadar. Düzenli bir kapanışın bazı yanlarını gerçekleştirmek istiyorum, bu yüzden iş parçacığı uyanmak için iş parçacığı eşitleme ilkelerini kullanın ve çıkması için sinyal verin, sonra iş parçacığı üzerinde tamamlamak için beklemek için bir pthread_join() gerçekleştirin. Bu kilitleme komutunu verdiğimde, iş parçacığı bir connect() aramanın ortasında değilse harika çalışıyor. Bu durumda, bağlantıyı zaman aşımına uğratmak zorundayım, bu da uzun bir zaman olabilir. Bu, uygulamanın kapatılması uzun sürüyor gibi görünüyor.

Yapmak istediklerim, bir şekilde connect() aramasına aramayı kesmektir. Çağrı geri döndükten sonra, iş parçacığı çıkış sinyalimi fark edecek ve temiz bir şekilde kapanacaktır. connect() bir sistem çağrısı olduğundan, bir sinyal kullanarak kasıtlı olarak kesebileceğimi düşündüm (bu nedenle EINTR numaralı çağrıyı geri döndürür), ancak POSIX iş parçacıklarında sağlam bir yöntem olup olmadığından emin değilim.

Sinyalleri veya başka bir yöntem kullanarak, bunun nasıl yapılacağı konusunda herhangi bir önerisi var mı? Bir not olarak, connect() çağrısı bazı kütüphane kodlarında değiştiremediğim için, engelleme olmayan bir yuvaya geçmek bir seçenek değildir.

Answer 1

deneyin için close() soket () bağlamak kesmek. Emin değilim, ama en azından Linux üzerinde çalışacağını düşünüyorum. Tabii ki, düzgün bir şekilde yakın() bu soketi bir kez ya da bir close()'un yeni açılmış olan bir dosya tanımlayıcısını teorik olarak kapatabilirsiniz.

DÜZENLEME: aslında soket kapatmadığı için kapatma() daha uygun olabilir.

Alternatif olarak, pthread_cancel() ve pthread_kill()'a bakmak isteyebilirsiniz. Ancak, bu ikisini yarış durumu olmadan kullanmanın bir yolunu görmüyorum.

Çok işlemcili sunucu yaklaşımını terk etmenizi ve etkinlik bildirimi için örneğin epoll'u kullanarak olaya dayalı gitmenizi tavsiye ederim. Bu şekilde, uygun kapatma gibi iş parçacıkları ile çok zor hale gelen tüm bu çok temel sorunları önleyebilirsiniz. İstediğiniz zaman herhangi bir anda yapmakta özgürsünüz, ör. Soketleri güvenli bir şekilde kapatın ve bir daha asla onlardan haber alamazsınız. Öte yandan

, sizin çalışan iş parçacığı bir (veya)() ( bağlayıp epoll_pwait yoluyla haberdar olsun engellenmeyen ppoll yaparsanız() veya pSELECT(); p not), sinyallerle ilgili yarış koşullarından kaçınabilirsiniz.