0

次のようなクライアント プログラムがあり、マルチスレッド化する必要があります。つまり、接続ごとに 1 つのスレッドです。ただし、変数 sockfd は 1 つのスレッドに対してグローバルに保持されます。これを行うには、pthread_key_t、pthread_key_create...などを使用する必要があることを理解しています。でも、使い方に困っています。どんな助けにも感謝します。

int sockfd;
pthread_key_t key_to_sockfd;

void error(const char *msg)
{
   perror(msg);
   exit(0);
}


void set_connection(char *argv[])
{

   int portno;
   struct sockaddr_in serv_addr;
   struct hostent *server;

   char buffer[256];
   portno = atoi(argv[2]);
   sockfd = socket(AF_INET, SOCK_STREAM, 0);
   if (sockfd < 0) 
       error("ERROR opening socket");
   server = gethostbyname(argv[1]);
   if (server == NULL) {
       fprintf(stderr,"ERROR, no such host\n");
       exit(0);
 }
bzero((char *) &serv_addr, sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
bcopy((char *)server->h_addr, 
(char *)&serv_addr.sin_addr.s_addr,server->h_length);
serv_addr.sin_port = htons(portno);
if (connect(sockfd,(struct sockaddr *) &serv_addr,sizeof(serv_addr)) < 0) 
    error("ERROR connecting");
return;
}

void send_message()
{
    char buffer[256];
    int i=0,n;
    do{
      printf("Please enter the message: ");
      bzero(buffer,256);
      fgets(buffer,255,stdin);
       n = write(sockfd,buffer,strlen(buffer));
      if (n < 0) 
        error("ERROR writing to socket");
    i++;
 }while(i<3);
bzero(buffer,256);
n = read(sockfd,buffer,255);
if (n < 0) 
     error("ERROR reading from socket");
printf("%s\n",buffer);
return;
}

void disconnect()
{
   close(sockfd);
   return;
}

void client_thrd(char *argv[])
{
  set_connection(argv);
  send_message();
  disconnect();
}
int main(int argc, char *argv[])
{

pthread_t thid[2];  
int i;  
void *status;
if (argc < 3) {
   fprintf(stderr,"usage %s hostname port\n", argv[0]);
   exit(0);
}
for(i=0;i<1;i++)
    pthread_create(&thid[i],NULL,(void*)&client_thrd,(void*)argv);
for(i=0;i<1;i++)
    pthread_join(thid[i],&status);


return 0;
}

1 つのスレッドに対してプログラムを実行しましたが、正常に動作します。しかし、スレッドの数を1つ以上に増やすと、グローバルな利用可能なsockfdのために機能しません。これはもっと大きなもののためのテストプログラムです。

感謝と敬意

4

3 に答える 3

3

とても使いやすいです。プログラムの開始時に呼び出すpthread_key_create(&key_to_sockfd, NULL)と、各スレッドにNULLの初期値が表示されます。pthread_setspecific(key_to_sockfd, <pointer to a struct which contains sockfd>)各スレッドで関数を使用します。

それ以降、各スレッドには、sockfdを含む構造体への異なるポインターが表示されます。スレッドが完成したら、構造を削除して使用しますpthread_setspecific(key_to_sockfd, NULL)

スレッドが終了したらpthread_key_delete(key_to_sockfd)、ストレージを削除するために呼び出します。pthread_key_createスレッドが終了したときにメモリを解放するためのコールバック関数を提供することにより、自動的にクリーンアップすることもできます。

于 2011-09-14T06:03:02.897 に答える
2

私が見たところ、やりたいことを達成するためにグローバル変数は必要ありません。「状態」データ構造を作成し、起動する前にスレッドごとに初期化します。void*スレッド インターフェイスのパラメーターは、このために作成されます。

于 2011-09-14T06:06:16.437 に答える
0

あなたのコードを見ると、スレッドごとに上書きして、ソケット記述子 sockfd を開始します。したがって、各スレッドは新しい接続を確立し、新しい sockfd を取得します。このコードを使用すると、あるスレッドが別のスレッドの接続を閉じている可能性が高くなります。各スレッドに独自のソケット記述子を使用したい場合は、ポインタを使用して同じスレッド内で同じソケット記述子を共有してみませんか?

void client_thrd(char *argv[])
{
  int sockfd;
  set_connection(&sockfd, argv);
  send_message(&sockfd);
  disconnect(&sockfd);
}
于 2011-09-14T06:07:42.007 に答える